Re: 回复: Difference between JobManager and JobMaster

2020-01-31 Thread Chesnay Schepler
*发件人:* Yun Tang *发送时间:* 2020年1月31日 15:20 *收件人:* Lu Weizheng ; user@flink.apache.org *主题:* Re: Difference between JobManager and JobMaster Hi Wizheng FLIP-6 [1] introduce a new implementation of master component in Flink cluster with name of `JobMaster.java`[2], you can find previous

回复: Difference between JobManager and JobMaster

2020-01-31 Thread Lu Weizheng
Weizheng ; user@flink.apache.org 主题: Re: Difference between JobManager and JobMaster Hi Wizheng FLIP-6 [1] introduce a new implementation of master component in Flink cluster with name of `JobMaster.java`[2], you can find previous implementation in Flink-1.7 as `JobManager.scala` [3]. However, we

Re: Difference between JobManager and JobMaster

2020-01-30 Thread Yun Tang
nt: Friday, January 31, 2020 10:25 To: user@flink.apache.org Subject: Difference between JobManager and JobMaster Hi all, Recently I am reading source code of Flink. There are both JobManager and JobMaster in flink-runtime project. And JobManagerRunner interface says it is a runner which executes a

Difference between JobManager and JobMaster

2020-01-30 Thread Lu Weizheng
Hi all, Recently I am reading source code of Flink. There are both JobManager and JobMaster in flink-runtime project. And JobManagerRunner interface says it is a runner which executes a JobMaster. So how to distinguish the two concepts? Is JobMaster a subset of JobManager? Or JobMaster is a new