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 7a480aab456 [fix](nereids) Push max rf into cte #34858
7a480aab456 is described below
commit 7a480aab4567dbdf90c2c728e7f8c24cae02c9f1
Author: minghong <[email protected]>
AuthorDate: Tue May 14 21:05:18 2024 +0800
[fix](nereids) Push max rf into cte #34858
---
fe/fe-core/src/main/java/org/apache/doris/common/IdGenerator.java | 4 ++++
.../apache/doris/nereids/processor/post/RuntimeFilterGenerator.java | 2 +-
.../org/apache/doris/nereids/trees/plans/physical/RuntimeFilter.java | 4 ++--
3 files changed, 7 insertions(+), 3 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/IdGenerator.java
b/fe/fe-core/src/main/java/org/apache/doris/common/IdGenerator.java
index b244010dc30..89267166bac 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/IdGenerator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/IdGenerator.java
@@ -34,4 +34,8 @@ public abstract class IdGenerator<IdType extends Id<IdType>> {
}
public abstract IdType getNextId();
+
+ public int getCurrentId() {
+ return nextId;
+ }
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java
index 420e25126da..5722fa527db 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java
@@ -573,7 +573,7 @@ public class RuntimeFilterGenerator extends
PlanPostProcessor {
RuntimeFilter filter = new
RuntimeFilter(generator.getNextId(),
rf.getSrcExpr(), targetList, targetExpressions,
rf.getType(), rf.getExprOrder(),
rf.getBuilderNode(), buildSideNdv,
rf.isBloomFilterSizeCalculatedByNdv(),
- cteNode);
+ rf.gettMinMaxType(), cteNode);
targetNodes.forEach(node ->
node.addAppliedRuntimeFilter(filter));
for (Slot slot : targetList) {
ctx.setTargetExprIdToFilter(slot.getExprId(), filter);
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/RuntimeFilter.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/RuntimeFilter.java
index 9f810e73ecc..b2b078aaebf 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/RuntimeFilter.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/RuntimeFilter.java
@@ -58,11 +58,11 @@ public class RuntimeFilter {
*/
public RuntimeFilter(RuntimeFilterId id, Expression src, List<Slot>
targets, List<Expression> targetExpressions,
TRuntimeFilterType type, int exprOrder,
AbstractPhysicalJoin builderNode, long buildSideNdv,
- boolean bloomFilterSizeCalculatedByNdv,
+ boolean bloomFilterSizeCalculatedByNdv,
TMinMaxRuntimeFilterType tMinMaxType,
PhysicalRelation scan) {
this(id, src, targets, targetExpressions, type, exprOrder,
builderNode, false, buildSideNdv,
bloomFilterSizeCalculatedByNdv,
- TMinMaxRuntimeFilterType.MIN_MAX, scan);
+ tMinMaxType, scan);
}
public RuntimeFilter(RuntimeFilterId id, Expression src, List<Slot>
targets, List<Expression> targetExpressions,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
