[FLINK-17020] Introduce GlobalDataExchangeMode for JobGraph Generation

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.11.0
• Fix Version/s: 1.11.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Zhu Zhu
• Reporter: Zhu Zhu
• Created: 07/Apr/20 06:38
• Updated: 24/Apr/20 07:11
• Resolved: 24/Apr/20 07:11

Description

Introduce GlobalDataExchangeMode with 4 modes:

• ALL_EDGES_BLOCKING
• FORWARD_EDGES_PIPELINED
• POINTWISE_EDGES_PIPELINED
• ALL_EDGES_PIPELINED

StreamGraph will be extended with a new field to host the GlobalDataExchangeMode. In the JobGraph generation stage, this mode will be used to determine the data exchange type of each job edge.

More details see FLIP-119#Global Data Exchange Mode

Issue Links

• links to: GitHub Pull Request #11774