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 _111-b14)
Java HotSpot(TM) -Bit Server VM (build -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目錄中執行

• 1

6、待補充，通過web界面送出jar包