[FLINK-13041] Make ScheduleMode configurable on ExecutionConfig

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Won't Do
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 01/Jul/19 09:51
• Updated: 05/Jul/19 11:39
• Resolved: 05/Jul/19 11:39

Description

The new Blink-based Table API Runner currently needs a way of globally setting the ScheduleMode (either LAZY_FROM_SOURCES or EAGER) to support both batch-style and streaming-style execution.

This is a stop-gap solution. Ideally, Transformations would know whether they are bounded or not and the scheduler could decide the scheduling mode based on that information but this requires more work on both the Table API Runner and the DAG API.

Issue Links

• relates to: FLINK-12961 StreamExecutionEnvironment supports executing job with StreamGraph
• links to: GitHub Pull Request #8931