無論以什么樣的模式提交Application到Yarn中運行，都會啟動一個yarn-session(Flink 集群)，依然是由JobManager和TaskManager組成，那么JobManager節點如果宕機，那么整個Flink集群就不會正常運轉，所以接下來搭建Flink on YARN HA集群

安裝步驟

hadoop/yarn-site.xml

<property> <name>yarn.resourcemanager.am.max-attempts</name> <value>10</value> <description> The maximum number of application master execution attempts AppMaster最大 重試次數 </description> </property>

分發至其他節點：并重啟

flink/flink-conf.yaml

HA測試

Application Master就是Job Manager。
在node02上kill掉JM進程后，發現JM又會在node04上重啟，已經實現了HA：


查看node04的日志：

提交一個flink job：

總結

以上是生活随笔為你收集整理的flink on yarn HA高可用集群搭建的全部內容，希望文章能夠幫你解決所遇到的問題。

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