You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2025/07/01 19:57:00 UTC

[jira] [Created] (FLINK-38037) Configure hashDistribution with commonJoinKey

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)