![Flink与Kylin深度实践](https://wfqqreader-1252317822.image.myqcloud.com/cover/467/37323467/b_37323467.jpg)
上QQ阅读APP看书,第一时间看更新
2.3 standalone模式的HA环境
上一节实现了Flink的standalone模式部署安装,并且能够正常提交任务到集群上。其中的主节点是JobManager,但JobManager是单节点,必然会有单节点故障问题产生,所以也可以在standalone模式下借助ZK将JobManager实现为高可用模式。
首先停止Flink的standalone模式,并启动ZK和Hadoop集群服务。
1.修改配置文件
在node01上执行以下命令修改Flink的配置文件。
1)修改flink-conf.yaml配置文件。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/27_01.jpg?sign=1739595818-wa8CyswZuyVo2mLH6DM1XJ1hY4oBYsMN-0-3e061e4fa911edfa80ac08e5a1579ff4)
2)修改masters配置文件。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/27_02.jpg?sign=1739595818-yKfdxRSFSUAwV984bXYew57THA6mmnr8-0-6ee15fcbfcd9e5d533a40c69f5712603)
3)修改slaves配置文件。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/27_03.jpg?sign=1739595818-vgdqPzvcR7EY5FTGsYhdWxRq3bzOrtlU-0-7bf2d630808303fbdfc36906aa1ccc8b)
2.在HDFS上创建flink文件夹
在node01上执行以下命令。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/27_04.jpg?sign=1739595818-qHJj4SYjpwJMsXhGCcofuNkY7qxxBdzd-0-1ecfe668ab86074251dd90c1aa4d82c8)
3.复制配置文件
将node01服务器修改后的配置文件复制到其他服务器上,命令如下。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/27_05.jpg?sign=1739595818-jTB7w3BlHZVp7ntS00YaulIOdGiBmsH2-0-e5f9ccb9cceca4fcc11aa42d8fbf8ca1)
4.启动Flink集群
在node01上执行以下命令。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/27_06.jpg?sign=1739595818-6Mcry2cviOiv93VV0ur5ePOp50jy218g-0-6c7a4c7ef893ce0827766203d3e41b66)
5.访问页面
访问node01服务器的Web页面,直接在浏览器中访问http://node01:8081/#/overview;node02服务器的Web页面为http://node02:8081/#/overview,node03类似。
注意:
访问node02的Web页面时会自动跳转到node01的Web页面上,因为此时node01服务器才是真正活跃(active)的节点。
6.模拟宕机情况实现自动切换
将node01服务器的JobManager进程关闭,过一段时间之后查看node02的JobManager是否能够访问。注意:JobManager发生切换时,TaskManager也会跟着重启。