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