提交方式

一般都是提交到yarn上，當然單機也是可以跑的，而且單機不用安裝flink和hadoop

第一種提交到yarn的方法

提交到yarn-cluster

flink -m yarn-cluster -c className -j *.jar -d > log.log 2>&1 &

第二種提交到yarn的方法

先啟一個yarn-session，在yarn上開辟一塊資源，這時會生成一個yid，然后向這個資源池里提交任務

yarn-session.sh -n 9 -tm 1024 -s 4 -nm Name -d

然后向這個yid中提交job

flink run -c className -j *.jar -yid application_id -d > log.log 2>&1 &

兩種提交yarn的區別

個人理解第一種方法各種配置比較個性化，第二種可以在yarn上開辟資源，往session中提交多個job

總結

以上是生活随笔為你收集整理的flink 7-提交任务的全部內容，希望文章能夠幫你解決所遇到的問題。

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