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 e6b6c524fb..d844df6e1a 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 implem @Override public Plan visitLogicalCTEAnchor( LogicalCTEAnchor 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 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 producer = consumerContext.cteProducerList.get(i); child2 = new LogicalCTEAnchor<>(producer.getCteId(), producer, child2); @@ -131,7 +131,7 @@ public class OrExpansion extends DefaultPlanRewriter implem @Override public Plan visitLogicalJoin(LogicalJoin join, OrExpandsionContext ctx) { - join = (LogicalJoin) this.visit(join, ctx); + join = (LogicalJoin) join.accept(this, ctx); if (join.isMarkJoin() || !JoinUtils.shouldNestedLoopJoin(join)) { return join; }