[
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)
