首先是下載哪個壓縮包的問題:

[2]是pyflink，但是根據官方說目前屬于支持很初始的情況。

所以我們來下載[3]

?

配置文件	配置
$FLINK_HOME/conf/flink-conf.yaml	env.java.home: /home/appleyuchi/Java/jdk1.8.0_131
masters	Desktop:8081
slaves:	Desktop Laptop

文件和對應的進程

文件	對應的進程
masters	jobmanager
slaves	taskmanager

然后啟動flink即可,這樣一個兩個節點的真實的Flink集群就配置好了。

這里，稍微說一下，為什么上面的masters里面需要指定端口號呢？

因為這個是Flink的web ui的端口號，

訪問鏈接是:http://desktop:8081/#/overview

?

###################停止一個FLINK? JOB##############################################

FLINK的界面上貌似是沒法直接操作的額

(Python3.6) appleyuchi@Desktop:Flink$ flink list
Waiting for response...
------------------ Running/Restarting Jobs -------------------
06.06.2020 14:03:10 : 0b3f583e4123f8522d74ad611ca3b9bb : Socket Window WordCount (RUNNING)
--------------------------------------------------------------
(Python3.6) appleyuchi@Desktop:Flink$:flink cancel 0b3f583e4123f8522d74ad611ca3b9bb
Cancelling job 0b3f583e4123f8522d74ad611ca3b9bb.
Cancelled job 0b3f583e4123f8522d74ad611ca3b9bb

另外一種辦法是在web ui上面操作:

右上角點擊Cance Job即可

#################################################################

?

Reference:

[1]Flink集群部署詳細步驟

[2]http://archive.apache.org/dist/flink/flink-1.10.1/apache-flink-1.10.1.tar.

[3]https://mirrors.tuna.tsinghua.edu.cn/apache/flink/flink-1.10.1/flink-1.10.1-bin-scala_2.12.tgz

[4]Flink架構、原理與部署測試

總結

以上是生活随笔為你收集整理的flink配置+停止flink中的job的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。