在bin/flink-console.sh中，flinkzookeeperquorumpeer被列为flink可以运行的服务之一。flinkzookeeperquorumpeer是干什么的？哪一个flink需要使用zookeeper并为它运行一个独立的服务？如果是为了job manager的高可用性，为什么我们不把它作为job manager的一部分呢？
(zookeeper)
CLASS_TO_RUN=org.apache.flink.runtime.zookeeper.FlinkZooKeeperQuorumPeer
;;
1条答案
按热度按时间hts6caw31#
如文件所述
FlinkZooKeeperQuorumPeer是Zookeeper的简单 PackageQuorumPeer.QuorumPeer是负责管理仲裁协议的类，用于领导人选举机制。zookeeper的选择机制用于jobmanager高可用性模式设置为zookeeper. 基本上，在这种模式下，您将运行多个作业管理器，但其中只有一个将被标记为leader它将是唯一负责安排工作的人。如果领导人因故死亡或失去React，则使用zookepeer的选举机制进行选举，并选出新领导人。有关高可用性的更多信息，请参阅此处。更多关于Zookeeper选举本身。