Flink WordCount测试

参考文档
https://ci.apache.org/projects/flink/flink-docs-master/quickstart/setup_quickstart.html

windows上测试，linux上2017年4月的存档中有
1、准备工具。在百度或者google上搜索netcat-win32-1.11.zip。
运行nc64 -l -p 9099。启动监听程序

2、安装java

java version "1.8.0_111"
Java(TM) SE Runtime Environment (build 1.8.0_111-b14)
Java HotSpot(TM) 64-Bit Server VM (build 25.111-b14, mixed mode)

• 1
• 2
• 3

3、下载最新的flink1.4.0版本
解压
D:\flink-1.4.0-bin-hadoop27-scala_2.11\flink-1.4.0

4、启动flink的本地模式

D:\flink-1.4.0-bin-hadoop27-scala_2.11\flink-1.4.0\bin\local.bat

• 1

里面一共就只有三个程序可以在win上执行
分别是（flink）、flink.bat 、 pyflink.bat 、start-local.bat

5、提交任务
bin目录中执行

flink run ../examples/streaming/SocketWindowWordCount.jar --port 9099

• 1

6、待补充，通过web界面提交jar包