You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "TisonKun (JIRA)" <ji...@apache.org> on 2019/06/10 08:11:00 UTC

[jira] [Commented] (FLINK-12176) Unify JobGraph creation in CliFrontend

    [ https://issues.apache.org/jira/browse/FLINK-12176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859806#comment-16859806 ] 

TisonKun commented on FLINK-12176:
----------------------------------

Thanks for your clarification. I'd like to keep this JIRA and unmark the fix version for attaining time to dig it out.

> Unify JobGraph creation in CliFrontend
> --------------------------------------
>
>                 Key: FLINK-12176
>                 URL: https://issues.apache.org/jira/browse/FLINK-12176
>             Project: Flink
>          Issue Type: Improvement
>          Components: Command Line Client
>    Affects Versions: 1.9.0
>            Reporter: TisonKun
>            Assignee: TisonKun
>            Priority: Major
>
> Currently, we create {{JobGraph}} by the following process
> * if the cluster start in job mode, we create {{JobGraph}} by {{PackagedProgramUtils#createJobGraph}} and deploy a job cluster
> * if the cluster start in session mode, we create {{JobGraph}} and submit it by {{CliFrontend#executeProgram}}, which internally the same as above but using {{ContextEnvironment}} instead of {{OptimizerPlanEnvironment}}.
> {{ContextEnvironment}} not only create the job graph but also submit it. However, the processes of {{JobGraph}} creation in job mode and session mode are similar. That means, we can unify the process by always create {{JobGraph}} by {{PackagedProgramUtils#createJobGraph}}. And,
> * in job mode, deploy job cluster with the {{JobGraph}}
> * in session mode, submit the {{JobGraph}} to the session cluster
> From a higher view, it is helpful for a common view of job submission in both job and session mode and give opportunities to refactor legacy client codes.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)