[
https://issues.apache.org/jira/browse/FLINK-26168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-26168:
-------------------------------
Description: 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. (was: 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.)
> 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: Sub-task
> 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)
