flink 学习
Posted longjmp
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了flink 学习相关的知识,希望对你有一定的参考价值。
一、运行 SockWordCount例子
1、到官网上下载
flink-1.6.2-bin-hadoop27-scala_2.11.tgz
然后加压出来
2、cd flink-1.6.2
3、打开flink本地集群
./bin/start-cluster.sh
可以到 localhost.8100上看是否启动
4、打开一个网络cat
nc -l 9000
5、运行编译好的jar
./bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9000
6、在nc这边输入一些字符,每隔5秒钟flink就会统计一次字数
tail -f log/flink-xxx-taskexecutor.xxx.log 可以查看统计结果
7、关闭集群
./bin/stop-cluster.sh
以上是关于flink 学习的主要内容,如果未能解决你的问题,请参考以下文章