![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=1739363226-yIYbrtonjgEjsAwIgTgcp3itBxNqFhJF-0-8b368070a2c30f6aec8815f1c997ea7e)
2)修改masters配置文件。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/27_02.jpg?sign=1739363226-1QDuHCQNc8QjjHUQbhGOdUAnnr14tvxk-0-520284af1fbc174f29eb9785f64b26b5)
3)修改slaves配置文件。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/27_03.jpg?sign=1739363226-10mJBpMy1QwbAyZVmWDPfYOVV1flefRH-0-5465510800731e5a563762d9299cc5ac)
2.在HDFS上创建flink文件夹
在node01上执行以下命令。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/27_04.jpg?sign=1739363226-X1DaCdnXIUw8jjE9iV6MRQoXyHpnKh5i-0-00aee0fee62fc16df62e880fab26bfc8)
3.复制配置文件
将node01服务器修改后的配置文件复制到其他服务器上,命令如下。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/27_05.jpg?sign=1739363226-LGMRHHknieRFj690Lc6jqvGusklcNH1Q-0-e1ae3c650b6ebf628efdbe1fb15513ad)
4.启动Flink集群
在node01上执行以下命令。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/27_06.jpg?sign=1739363226-d69kFhGgZV8OpK1Fy4rjSwdnS0v7zy27-0-bd6bd69ffb7cb9b8b8b8d61a324c02d2)
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也会跟着重启。