[ https://issues.apache.org/jira/browse/FLINK-13062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-13062: ----------------------------------- Labels: pull-request-available (was: ) > Set ScheduleMode based on boundedness of streaming Pipeline > ----------------------------------------------------------- > > Key: FLINK-13062 > URL: https://issues.apache.org/jira/browse/FLINK-13062 > Project: Flink > Issue Type: Improvement > Components: API / DataStream > Reporter: Aljoscha Krettek > Assignee: Aljoscha Krettek > Priority: Major > Labels: pull-request-available > > The new Blink-based Table Runner needs "streaming pipelines" to be executed > with {{ScheduleMode.LAZY_FROM_SOURCES}} if all sources are bounded. The > current Blink code base uses a global flag for this and configures the > {{StreamGraphGenerator}} accordingly. > We propose to add an {{isBounded()}} property to {{Transformation}} (formerly > known as {{StreamTransformation}}). The property would only be explicitly > settable on sources, other transformations inherit the property from their > inputs. The {{StreamGraphGenerator}} must use > {{ScheduleMode.LAZY_FROM_SOURCES}} if all sources are bounded, otherwise, it > should use {{ScheduleMode.EAGER}}, as is the currently existing behaviour. -- This message was sent by Atlassian Jira (v8.3.4#803005)