我想以高可用性模式运行flink集群。因此,我已经按照jobmanager的高可用性设置到flink配置文件中。当我使用 start-zookeeper-quorum.sh
,我可以在两台机器上启动两个zookeerper服务器(对等机)。但是当我用两个jobmanagers启动flink集群时,我得到的信息是 Service temporarily unavailable due to an ongoing leader election. Please refresh.
在flink的web用户界面上。
这个按摩是什么意思?有没有办法在配置文件中通知领导者?
1条答案
按热度按时间eimct9ow1#
问题在于zookeeper的安装。zk节点不能选择引线。两个节点的数目也不是最佳选择。您应该至少有3个示例或其他更大的奇数。
你应该在这里查看zookeeper的管理文档