Gustavo de Morais created FLINK-38037:
-----------------------------------------
Summary: Configure hashDistribution with commonJoinKey
Key: FLINK-38037
URL: https://issues.apache.org/jira/browse/FLINK-38037
Project: Flink
Issue Type: Sub-task
Affects Versions: 2.1.0
Reporter: Gustavo de Morais
Assignee: Gustavo de Morais
Fix For: 2.1.0
We have a commonJoinKey for a series of joins that are merged into a multi join
operator.
For it to be possible to increase the parallelism and partitioning to work
correctly, we need to configure all inputs of the multi join physical node to
use hash distribution and use the appropriate commonJoinKey from their input.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
