[jira] [Updated] (FLINK-37890) Extend JoinToMultiJoinRule to check for common join key

["Gustavo de Morais (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-37890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Gustavo de Morais updated FLINK-37890:
--------------------------------------
    Summary: Extend JoinToMultiJoinRule to check for common join key  (was: Extend FlinkLogicalMultiJoin to check for common join key)

> Extend JoinToMultiJoinRule to check for common join key
> -------------------------------------------------------
>
>                 Key: FLINK-37890
>                 URL: https://issues.apache.org/jira/browse/FLINK-37890
>             Project: Flink
>          Issue Type: Sub-task
>            Reporter: Gustavo de Morais
>            Priority: Major
>
> We need to have the optimizer check if it's possible to use a StreamingMultiJoinOperator according the [common key restrictions|https://cwiki.apache.org/confluence/display/FLINK/FLIP-516%3A+Multi-Way+Join+Operator].
>  * Add Rule to check if the join chain respects the multi join common key restrictions
>  ** If not, create one multi join for each group of joins that respect. That means 9 chained joins, 3 have one common key and 6 have another will generate two chained multi joins.
>  ** This could be addressed in the new FlinkLogicalMultiJoin produced by FLINK-37889
> Related:
>  * Add FlinkLogicalMultiJoin with all parameters we need + FlinkJoinToFlinkMultiJoinRule to create it
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)