單機版部署

下載flink的包：https://archive.apache.org/dist/flink/flink-1.10.1/flink-1.10.1-bin-scala_2.12.tgz

我這裡把包放到/opt下面了，解壓：

cd /opt
tar -xvf flink-1.10.1-bin-scala_2.12.tgz
./bin/start-cluster.sh

啟動成功後，就可以進入web dashboard了（8081埠）：http://192.168.1.40:8081/

Task Managers資訊：

提交job執行

將上一節中的程式碼打成jar包：https://www.cnblogs.com/wwjj4811/p/15211936.html

上傳：

顯示執行計劃：

退出，點選submit

但是我們發現任務並不能執行成功。

這是因為我分配的Task Slots不夠。

重新配置flink後，重新啟動

vi conf/flink-conf.yaml

#這裡給當前機器的cpu個數
taskmanager.numberOfTaskSlots: 8

重新提交剛才的任務並執行，執行nc -lk 7777，發現flink可以收到輸入內容

標準輸出內容：

命令列提交job

-p表示三個並行度。

./bin/flink run -c com.wj.wc.StreamWordCount -p 3 /root/flink-demo-1.0-SNAPSHOT.jar --host 192.168.1.40 --port 7777
 

在running jobs這裡就能看到剛才提交的job

命令列取消job

檢視正在執行的job：

./bin/flink list

取消job：

./bin/flink cancel jobId