[jira] [Comment Edited] (FLINK-11619) Make ScheduleMode configurable via user code or configuration file

["Ji Liu (JIRA)" <ji...@apache.org>]

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

Ji Liu edited comment on FLINK-11619 at 4/10/19 9:03 AM:
---------------------------------------------------------

The default _ScheduleMode of JobGraph_ is LAZY_FROM_SOURCES, but when _StreamingJobGraphGenerator#createJobGraph_ is invoked, the scheduleMode is set to EAGER, and this value is passed to _ExecutionGraph_ later. So ScheduleMode.LAZY_FROM_SOURCES doesn't seem to be used anywhere, right? [~yuqi]


was (Author: tianchen92):
In default _ScheduleMod_e of _JobGraph_ is LAZY_FROM_SOURCES, but when _StreamingJobGraphGenerator#createJobGraph_ is invoked, the scheduleMode is set to EAGER, and this value is passed to _ExecutionGraph_ later. So ScheduleMode.LAZY_FROM_SOURCES doesn't seem to be used anywhere, right? [~yuqi]

> Make ScheduleMode configurable via user code or configuration file 
> -------------------------------------------------------------------
>
>                 Key: FLINK-11619
>                 URL: https://issues.apache.org/jira/browse/FLINK-11619
>             Project: Flink
>          Issue Type: Improvement
>          Components: API / DataStream
>            Reporter: yuqi
>            Assignee: yuqi
>            Priority: Major
>
> Currently, Schedule mode for stream job is always 
> see StreamingJobGraphGenerator#createJobGraph
> {code:java}
> // make sure that all vertices start immediately
> 		jobGraph.setScheduleMode(ScheduleMode.EAGER);
> {code}
> on this point, we can make ScheduleMode configurable to user so as to adapt different environment. Users can set this option via env.setScheduleMode() in code, or make it optional in configuration. 
> Anyone's help and suggestions is welcomed.



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