[ https://issues.apache.org/jira/browse/FLINK-17021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Zhu Zhu updated FLINK-17021: ---------------------------- Description: Blink planner config option "table.exec.shuffle-mode" should be extended to set GlobalDataExchangeMode for a job, values supported are: * ALL_EDGES_BLOCKING/batch * FORWARD_EDGES_PIPELINED * POINTWISE_EDGES_PIPELINED * ALL_EDGES_PIPELINED/pipelined Note that values 'pipelined' and 'batch' are still supported to be compatible: * ‘pipelined’ will be treated the same as ‘ALL_EDGES_PIPELINED’ * ‘batch’ will be treated the same as as ‘ALL_EDGES_BLOCKING’ Blink planner needs to set GlobalDataExchangeMode to StreamGraph according to the config value. was: 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. > 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 > Assignee: Zhu Zhu > Priority: Major > Labels: pull-request-available > 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_EDGES_BLOCKING/batch > * FORWARD_EDGES_PIPELINED > * POINTWISE_EDGES_PIPELINED > * ALL_EDGES_PIPELINED/pipelined > Note that values 'pipelined' and 'batch' are still supported to be compatible: > * ‘pipelined’ will be treated the same as ‘ALL_EDGES_PIPELINED’ > * ‘batch’ will be treated the same as as ‘ALL_EDGES_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)