[
https://issues.apache.org/jira/browse/FLINK-11619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814217#comment-16814217
]
Ji Liu commented on FLINK-11619:
--------------------------------
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)
