版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/dongdong9223/article/details/88819199
转载请注明出处:http://blog.csdn.net/dongdong9223/article/details/88819199
本文出自【我是干勾鱼的博客】
Ingredients:
-
Java:Java SE Development Kit 8u162(Oracle Java Archive),Linux下安装JDK并修改环境变量
-
Flink:flink-1.7.2-bin-scala_2.12.tgz(flink-1.7.2-bin-scala_2.12.tgz(mirror.bit.edu.cn/apache),Downloads,All Flink releases),Apache Flink® - Stateful Computations over Data Streams,Local Setup Tutorial,Examples
1 下载
wget -c http://mirror.bit.edu.cn/apache/flink/flink-1.7.2/flink-1.7.2-bin-scala_2.12.tgz
2 解压缩
将文件放到目录:
/opt/flink/flink-1.7.2
然后解压缩:
tar -zxvf flink-1.7.2-bin-scala_2.12.tgz
3 启动
./bin/start-cluster.sh
浏览器中可以看到图形界面:
4 监控日志
tail log/flink-*-standalonesession-*.log
5 示例
5.1 安装netcat
yum install -y nc
5.2 netcat启动本地服务
在终端上启动 netcat 获得输入流:
[root@shizhi002 flink-1.7.2]# nc -l 9000
hello world
这里输入了“hello world”这两个单词。
5.3 提交Flink程序
[root@shizhi002 flink-1.7.2]# ./bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9000
Starting execution of program
5.4 查看统计结果
使用命令查看统计输出结果:
[root@shizhi002 flink-1.7.2]# tail -f log/flink-root-taskexecutor-0-shizhi002.out
world : 1
Have : 1
注意:如果想要看到某个大于1的计数的单词,则在5秒内反复键入这个单词就可以实现。
5.5 界面显示
5.6 关闭Flink
./bin/stop-cluster.sh
6 参考
Building real-time dashboard applications with Apache Flink, Elasticsearch, and Kibana
Apache Flink 1.7 Documentation