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 c35fef631bb fix bug in or expansion (#34851)
c35fef631bb is described below
commit c35fef631bb48b6704c51fb4ddfa2ef46a6adeb4
Author: 谢健 <[email protected]>
AuthorDate: Tue May 14 19:39:33 2024 +0800
fix bug in or expansion (#34851)
---
.../java/org/apache/doris/nereids/rules/rewrite/OrExpansion.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/OrExpansion.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/OrExpansion.java
index e6b6c524fb7..d844df6e1a7 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/OrExpansion.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/OrExpansion.java
@@ -107,7 +107,7 @@ public class OrExpansion extends
DefaultPlanRewriter<OrExpandsionContext> implem
@Override
public Plan visitLogicalCTEAnchor(
LogicalCTEAnchor<? extends Plan, ? extends Plan> anchor,
OrExpandsionContext ctx) {
- Plan child1 = this.visit(anchor.child(0), ctx);
+ Plan child1 = anchor.child(0).accept(this, ctx);
// Consumer's CTE must be child of the cteAnchor in this case:
// anchor
// +-producer1
@@ -121,7 +121,7 @@ public class OrExpansion extends
DefaultPlanRewriter<OrExpandsionContext> implem
// +-consumer2 join consumer3
OrExpandsionContext consumerContext =
new OrExpandsionContext(ctx.statementContext,
ctx.cascadesContext);
- Plan child2 = this.visit(anchor.child(1), consumerContext);
+ Plan child2 = anchor.child(1).accept(this, consumerContext);
for (int i = consumerContext.cteProducerList.size() - 1; i >= 0; i--) {
LogicalCTEProducer<? extends Plan> producer =
consumerContext.cteProducerList.get(i);
child2 = new LogicalCTEAnchor<>(producer.getCteId(), producer,
child2);
@@ -131,7 +131,7 @@ public class OrExpansion extends
DefaultPlanRewriter<OrExpandsionContext> implem
@Override
public Plan visitLogicalJoin(LogicalJoin<? extends Plan, ? extends Plan>
join, OrExpandsionContext ctx) {
- join = (LogicalJoin<? extends Plan, ? extends Plan>) this.visit(join,
ctx);
+ join = (LogicalJoin<? extends Plan, ? extends Plan>) join.accept(this,
ctx);
if (join.isMarkJoin() || !JoinUtils.shouldNestedLoopJoin(join)) {
return join;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
