This is an automated email from the ASF dual-hosted git repository.

kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-2.0 by this push:
     new a1350e911d9 [fix](Nereids) rewrite cte children check wrong map for 
consumer (#28220) (#28572)
a1350e911d9 is described below

commit a1350e911d9eb32a511a023b36d9b01bc423e673
Author: morrySnow <[email protected]>
AuthorDate: Tue Dec 19 14:24:25 2023 +0800

    [fix](Nereids) rewrite cte children check wrong map for consumer (#28220) 
(#28572)
---
 .../java/org/apache/doris/nereids/rules/rewrite/RewriteCteChildren.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/RewriteCteChildren.java
 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/RewriteCteChildren.java
index 3318f9990d8..72a4603fadc 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/RewriteCteChildren.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/RewriteCteChildren.java
@@ -78,7 +78,7 @@ public class RewriteCteChildren extends 
DefaultPlanRewriter<CascadesContext> imp
             CascadesContext cascadesContext) {
         LogicalPlan outer;
         if 
(cascadesContext.getStatementContext().getRewrittenCteConsumer().containsKey(cteAnchor.getCteId()))
 {
-            outer = 
cascadesContext.getStatementContext().getRewrittenCteProducer().get(cteAnchor.getCteId());
+            outer = 
cascadesContext.getStatementContext().getRewrittenCteConsumer().get(cteAnchor.getCteId());
         } else {
             CascadesContext outerCascadesCtx = 
CascadesContext.newSubtreeContext(
                     Optional.empty(), cascadesContext, cteAnchor.child(1),


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to