ZhengYi Weng created FLINK-31750: ------------------------------------ Summary: Hash Keys are duplicate when join reorder happens in stream mode Key: FLINK-31750 URL: https://issues.apache.org/jira/browse/FLINK-31750 Project: Flink Issue Type: Bug Components: Table SQL / Planner Reporter: ZhengYi Weng Attachments: image-2023-04-07-10-39-13-831.png
When I run `JoinReorderTestBase#testAllInnerJoin` , I find hash keys are duplicate. !image-2023-04-07-10-39-13-831.png|width=571,height=263! The reason why it happens is that when join reorder, the join condition will change and generate the same column condition, for example,the condition of T1 join(T4 join T5)is a1 = a4 and a1 = a5. It can de fixed if columns in `StreamPhysicalJoinRuleBase#onMatch#toHashTraitByColumns` are not duplicate. I will fix it. -- This message was sent by Atlassian Jira (v8.20.10#820010)