database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](nereids) when runtimefilter target is null, skip the rf #34358

Browse Source
This commit is contained in:
minghong
2024-04-30 18:48:50 +08:00
committed by GitHub
parent 35f8563a75
commit 50855f01c7
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalHashJoin.java
View File

@ -251,8 +251,16 @@ public class PhysicalHashJoin<
Pair<PhysicalRelation, Slot> srcPair = ctx.getAliasTransferMap().get(srcExpr);
PhysicalRelation srcNode = (srcPair == null) ? null : srcPair.first;
Pair<PhysicalRelation, Slot> targetPair = ctx.getAliasTransferMap().get(probeExpr);
// when probeExpr is output slot of setOperator, targetPair is null
PhysicalRelation target1 = (targetPair == null) ? null : targetPair.first;
if (targetPair == null) {
/* cases for "targetPair is null"
1. when probeExpr is output slot of setOperator, targetPair is null
2. join (topn(table1), table2)
when aliasTransferMap goes through topn, all slots from table1
are cleared to avoid generate rf(table2->table1)
*/
return false;
}
PhysicalRelation target1 = targetPair.first;
PhysicalRelation target2 = null;
if (ConnectContext.get() != null && ConnectContext.get().getSessionVariable().expandRuntimeFilterByInnerJoin) {
if (!this.equals(builderNode)