You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by Jin Sun <is...@gmail.com> on 2018/10/04 00:06:40 UTC

Future of JobManager.scala

Hi Team,

 

What is the future of JobManager in org/apache/flink/runtime/jobmanager/JobManager.scala?

 

I noticed that there are some duplicate logic between JobManager.scala and JobMaster/Dispatcher, that somehow confuse me, and I also saw LegacyYarnClusterDescriptor.java depends on JobManager.scala, this sounds like JobManager.scale will deprecated, what is the future of JobManager.scala?  

 

Jin

Re: Future of JobManager.scala

Posted by Jin Sun <is...@gmail.com>.

Thanks Tzu-Li,

Then we can do some refactor/renaming, I opened https://issues.apache.org/jira/browse/FLINK-10494 under https://issues.apache.org/jira/browse/FLINK-10392 

Jin

On 10/3/18, 9:48 PM, "Tzu-Li Chen" <wa...@gmail.com> wrote:

    Hi Sun,
    
    JobManager.scala is component of legacy mode, they would be removed as a
    sub task of FLINK-10392[1].
    
    For the evolution from "legacy mode" to FLIP-6 new mode, see also [2]. For
    short, the previous JobManager is split mainly into JobMaster and
    Dispatcher.
    
    [1] https://issues.apache.org/jira/browse/FLINK-10392
    [2]
    https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65147077
    
    Best,
    tison.
    
    
    Jin Sun <is...@gmail.com> 于2018年10月4日周四 上午8:06写道：
    
    > Hi Team,
    >
    >
    >
    > What is the future of JobManager in
    > org/apache/flink/runtime/jobmanager/JobManager.scala?
    >
    >
    >
    > I noticed that there are some duplicate logic between JobManager.scala and
    > JobMaster/Dispatcher, that somehow confuse me, and I also saw
    > LegacyYarnClusterDescriptor.java depends on JobManager.scala, this sounds
    > like JobManager.scale will deprecated, what is the future of
    > JobManager.scala?
    >
    >
    >
    > Jin
    >
    >

Re: Future of JobManager.scala

Posted by Tzu-Li Chen <wa...@gmail.com>.

Hi Sun,

JobManager.scala is component of legacy mode, they would be removed as a
sub task of FLINK-10392[1].

For the evolution from "legacy mode" to FLIP-6 new mode, see also [2]. For
short, the previous JobManager is split mainly into JobMaster and
Dispatcher.

[1] https://issues.apache.org/jira/browse/FLINK-10392
[2]
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65147077

Best,
tison.


Jin Sun <is...@gmail.com> 于2018年10月4日周四 上午8:06写道：

> Hi Team,
>
>
>
> What is the future of JobManager in
> org/apache/flink/runtime/jobmanager/JobManager.scala?
>
>
>
> I noticed that there are some duplicate logic between JobManager.scala and
> JobMaster/Dispatcher, that somehow confuse me, and I also saw
> LegacyYarnClusterDescriptor.java depends on JobManager.scala, this sounds
> like JobManager.scale will deprecated, what is the future of
> JobManager.scala?
>
>
>
> Jin
>
>