Zhu Zhu created FLINK-17021: ------------------------------- Summary: Blink Planner set GlobalDataExchangeMode Key: FLINK-17021 URL: https://issues.apache.org/jira/browse/FLINK-17021 Project: Flink Issue Type: Sub-task Components: Runtime / Coordination, Table SQL / Planner Affects Versions: 1.11.0 Reporter: Zhu Zhu Fix For: 1.11.0
Blink planner config option "table.exec.shuffle-mode" should be extended to set GlobalDataExchangeMode for a job, values supported are: * all-blocking/batch --> ALL_EDGES_BLOCKING * forward-pipelined-only --> FORWARD_EDGES_PIPELINED * pointwise-pipelined-only --> POINTWISE_EDGES_PIPELINED * all-pipelined/pipelined --> ALL_EDGES_PIPELINED Note that values 'pipelined' and 'batch' are still supported to be compatible: * ‘pipelined’ will be treated the same as ‘all-pipelined’ * ‘batch’ will be treated the same as as ‘all-blocking’ Blink planner needs to set GlobalDataExchangeMode to StreamGraph according to the config value. -- This message was sent by Atlassian Jira (v8.3.4#803005)