xingbe created FLINK-37333:
------------------------------
Summary: Use ForwardForUnspecifiedPartitioner when adaptive
broadcast join takes effect
Key: FLINK-37333
URL: https://issues.apache.org/jira/browse/FLINK-37333
Project: Flink
Issue Type: Sub-task
Components: Runtime / Coordination
Affects Versions: 2.0.0
Reporter: xingbe
Fix For: 2.0.0
According to the design, we need to change the original forward partitioner to
a rescale partitioner after the adaptive broadcast join takes effect.
Accordingly, we need to use ForwardForUnspecifiedPartitioner to achieve this
purpose.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
