Какого рода споры, которые необходимо решить с помощью LeaderElectionService? - PullRequest
Новая
       16

Какого рода споры, которые необходимо решить с помощью LeaderElectionService?

0 голосов
/ 27 мая 2019

Флинк имеет следующий комментарий в LeaderElectionService.java

https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/LeaderElectionService.java#L26

Какого рода споры намеревается решить этот класс? 

 * Interface for a service which allows to elect a leader among 
   a group of contenders.
 * Prior to using this service, it has to be started calling 
   the start method. The start method
 * takes the contender as a parameter. If there are multiple 
   contenders, then each contender has
 * to instantiate its own leader election service.

1 Ответ

0 голосов
/ 27 мая 2019

Начиная с Flink 1.8, есть два класса, которые реализуют интерфейс LeaderContender. JobManagerRunner и WebMonitorEndpoint требуется высокая доступность и необходим сервис LeaderElectionService. 

public class JobManagerRunner implements LeaderContender, 
                     OnCompletionActions, AutoCloseableAsync {...

public class WebMonitorEndpoint<T extends RestfulGateway> 
    extends RestServerEndpoint implements LeaderContender, JsonArchivist {...
...