[jira] [Created] (FLINK-13041) Make ScheduleMode configurable on ExecutionConfig

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-13041) Make ScheduleMode configurable on ExecutionConfig

Shang Yuanchun (Jira)
Aljoscha Krettek created FLINK-13041:
----------------------------------------

             Summary: Make ScheduleMode configurable on ExecutionConfig
                 Key: FLINK-13041
                 URL: https://issues.apache.org/jira/browse/FLINK-13041
             Project: Flink
          Issue Type: Improvement
          Components: API / DataStream
            Reporter: Aljoscha Krettek
            Assignee: Aljoscha Krettek


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.



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