flink 学习

一、运行 SockWordCount例子

1、到官网上下载

p.p1 { margin: 0.0px 0.0px 0.0px 0.0px; font: 14.0px Monaco; color: #f4f4f4; background-color: #000000 }
span.s1 { }

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

p.p1 { margin: 0.0px 0.0px 0.0px 0.0px; font: 14.0px Monaco; color: #f4f4f4; background-color: #000000 }
span.s1 { }

./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

原文地址：https://www.cnblogs.com/longjmp/p/10035767.html