This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 60e5583b01f [fix](nereids-Branch-2.1) fix bug: try to prune a
not-exist rf #34630
60e5583b01f is described below
commit 60e5583b01fb49d89a5c85b633380f70a4857c35
Author: minghong <[email protected]>
AuthorDate: Fri May 10 14:28:19 2024 +0800
[fix](nereids-Branch-2.1) fix bug: try to prune a not-exist rf #34630
---
.../org/apache/doris/nereids/processor/post/RuntimeFilterContext.java | 3 ++-
.../org/apache/doris/nereids/processor/post/RuntimeFilterPruner.java | 2 +-
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterContext.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterContext.java
index c8ffffa12e5..7b6ee195214 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterContext.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterContext.java
@@ -45,6 +45,7 @@ import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import com.google.common.collect.Sets;
+import java.util.ArrayList;
import java.util.Collections;
import java.util.Iterator;
import java.util.List;
@@ -353,7 +354,7 @@ public class RuntimeFilterContext {
}
public List<ExprId> getTargetExprIdByFilterJoin(AbstractPhysicalJoin join)
{
- return joinToTargetExprId.get(join);
+ return joinToTargetExprId.getOrDefault(join, new ArrayList<>());
}
public SlotReference getCorrespondingOlapSlotReference(SlotReference slot)
{
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterPruner.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterPruner.java
index fb6e54e38a8..f85e5eebd26 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterPruner.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterPruner.java
@@ -155,7 +155,7 @@ public class RuntimeFilterPruner extends PlanPostProcessor {
context.getRuntimeFilterContext().addEffectiveSrcNode(join,
childType);
} else {
List<ExprId> exprIds = rfContext.getTargetExprIdByFilterJoin(join);
- if (exprIds != null && !exprIds.isEmpty()) {
+ if (!exprIds.isEmpty()) {
boolean isEffective = false;
for (Expression expr : join.getEqualToConjuncts()) {
if (isEffectiveRuntimeFilter((EqualTo) expr, join)) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
