[ https://issues.apache.org/jira/browse/FLINK-26168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Zhu Zhu closed FLINK-26168. --------------------------- Resolution: Done master/release-1.15: 8f3a0251d195ed2532abc31e602029dfcbf7bc77 > The judgment of chainable ignores StreamExchangeMode when partitioner is > ForwardForConsecutiveHashPartitioner > ------------------------------------------------------------------------------------------------------------- > > Key: FLINK-26168 > URL: https://issues.apache.org/jira/browse/FLINK-26168 > Project: Flink > Issue Type: Bug > Reporter: Lijie Wang > Assignee: Lijie Wang > Priority: Major > Labels: pull-request-available > Fix For: 1.15.0 > > > After FLINK-26167, if the exchange mode is set as {{ALL_EDGES_BLOCKING}} > through {{{}table.exec.shuffle-mode{}}}, the shuffle mode of > {{ForwardForConsecutiveHashPartitioner}} will be set as {{BATCH}} (becase it > may be converted to hash shuffle). But it should not affect the chain > creation, so we need chang the chain logic and let the judgment of chainable > ignores StreamExchangeMode when partitioner is > ForwardForConsecutiveHashPartitioner. -- This message was sent by Atlassian Jira (v8.20.1#820001)