Что такое FlinkZooKeeperQuorumPeer для Flink? - PullRequest
0 голосов
/ 26 мая 2019

в bin / flink-console.sh, FlinkZooKeeperQuorumPeer указан как один из сервисов, которые могут работать. Для чего нужен FlinkZooKeeperQuorumPeer? В какой момент нужно использовать zookeeper и запустить для него автономный сервис? Если это для высокой доступности менеджера работы, почему бы нам не поставить в качестве менеджера работы?

   (zookeeper)

CLASS_TO_RUN=org.apache.flink.runtime.zookeeper.FlinkZooKeeperQuorumPeer
;;

1 Ответ

1 голос
/ 26 мая 2019

Как указано в документации, FlinkZooKeeperQuorumPeer - это простая оболочка для ZooKeeper QuorumPeer.QuorumPeer - это класс, который отвечает за управление протоколом кворума, который используется для механизма выбора лидера.Механизм выбора Zookeeper используется в случае, если режим высокой доступности JobManager установлен на zookeeper.По сути, в этом режиме у вас будет запущено несколько JobManager, но только один из них будет помечен как leader, и он действительно будет единственным, ответственным за планирование заданий.Если лидер по какой-либо причине умирает или перестает отвечать, то выборы проводятся с использованием механизма выборов Zookepeer, и выбирается новый лидер.Подробнее о высокой доступности можно найти здесь . Подробнее о самих выборах зоопарков здесь.

...