From c35fef631bb48b6704c51fb4ddfa2ef46a6adeb4 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=B0=A2=E5=81=A5?= <jianxie0@gmail.com>
Date: Tue, 14 May 2024 19:39:33 +0800
Subject: [PATCH] fix bug in or expansion (#34851)

---
 .../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 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<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;
         }