Re: Purpose of starting LeaderRetrievalService in DefaultDispatcherResourceManagerComponentFactory#create

2020-07-02 Thread Andrey Zagrebin
Hi Linlin, There may be a historic confusion in terminology. We often refer to 'JobManager' as a component which manages a single job. Names of all related classes usually contain 'JobManager'. At the same time, we can refer to it as a master process in Flink's cluster, potentially running multipl

Purpose of starting LeaderRetrievalService in DefaultDispatcherResourceManagerComponentFactory#create

2020-06-30 Thread Linlin Zhou
Hi, I'm reading flink runtime source code recently, and I found that when create DispatcherResourceManagerComponent in {@link org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory#create}, it will start DispatcherLeaderRetrieverService and ResourceManage