[FLINK-19392] Detect the execution mode based on the sources in the job.

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Affects Version/s: 1.12.0
• Fix Version/s: 1.12.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Kostas Kloudas
• Reporter: Kostas Kloudas
• Created: 24/Sep/20 07:28
• Updated: 19/Feb/21 07:32
• Resolved: 01/Oct/20 07:21

Description

As part of FLIP-134, we introduce the option execution.runtime-mode which can take the values: BATCH, STREAMING, and AUTOMATIC.

In case of the latter, the system will scan the sources and detect if the job is to be execute either using batch scheduling or streaming. If all the sources are bounded, the system will go with BATCH, if at least one is unbounded, then the system will go with STREAMING.

This issue targets introducing the logic of detecting the runtime mode based on the sources without exposing it yet to the user. The latter will happen in a follow-up issue.

Issue Links

• links to: GitHub Pull Request #13502