1. 程式人生 > >flink1.7學習筆記一之安裝篇

flink1.7學習筆記一之安裝篇

下載地址:https://mirrors.tuna.tsinghua.edu.cn/apache/flink/flink-1.7.0/flink-1.7.0-bin-hadoop28-scala_2.12.tgz

解壓:tar -zxvf flink-1.7.0-bin-hadoop28-scala_2.12.tgz -C /opt

啟動flink:bin/start-cluster.sh 

頁面訪問flink:http://192.168.80.129:8081/   =》結果顯示空白,暫時未研究。

檢視flink程序:ps -ef|grep flink

jps檢視程序:jps

模擬flink計算單詞例子:nc -l 9000

另起一個視窗輸入:bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9000

再起一個視窗檢視計算結果:tail -f flink-root-taskexecutor-0-ubuntu.out 

第一個視窗輸入:

第三個視窗結果如下:

上面顯示每次輸入一行資料裡面,每個單詞出現的次數值。