[incubator-doris] branch master updated: Fix MaterializedView select with CTE bug (#5165)

[kangkaisen]

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

kangkaisen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git


The following commit(s) were added to refs/heads/master by this push:
     new bcf1091  Fix MaterializedView select with CTE bug (#5165)
bcf1091 is described below

commit bcf1091043c4d617af96dd444b9be7eb75415e63
Author: kangkaisen <kangkai...@apache.org>
AuthorDate: Mon Jan 4 13:42:29 2021 +0800

    Fix MaterializedView select with CTE bug (#5165)
---
 .../src/main/java/org/apache/doris/planner/SingleNodePlanner.java  | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/planner/SingleNodePlanner.java 
b/fe/fe-core/src/main/java/org/apache/doris/planner/SingleNodePlanner.java
index ac34505..8a4bc83 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/SingleNodePlanner.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/SingleNodePlanner.java
@@ -73,7 +73,6 @@ import java.util.List;
 import java.util.Map;
 import java.util.HashSet;
 import java.util.Set;
-import java.util.UUID;
 
 /**
  * Constructs a non-executable single-node plan from an analyzed parse tree.
@@ -86,7 +85,7 @@ public class SingleNodePlanner {
 
     private final PlannerContext ctx_;
     private final ArrayList<ScanNode> scanNodes = Lists.newArrayList();
-    private Map<UUID, List<ScanNode>> selectStmtToScanNodes = 
Maps.newHashMap();
+    private Map<Analyzer, List<ScanNode>> selectStmtToScanNodes = 
Maps.newHashMap();
 
     public SingleNodePlanner(PlannerContext ctx) {
         ctx_ = ctx;
@@ -778,7 +777,7 @@ public class SingleNodePlanner {
                             ((InlineViewRef) tableRef).getAnalyzer());
                 }
             }
-            List<ScanNode> scanNodeList = 
selectStmtToScanNodes.get(selectStmt.getId());
+            List<ScanNode> scanNodeList = 
selectStmtToScanNodes.get(selectStmt.getAnalyzer());
             if (scanNodeList == null) {
                 return selectFailed;
             }
@@ -1455,7 +1454,7 @@ public class SingleNodePlanner {
         analyzer.materializeSlots(scanNode.getConjuncts());
 
         scanNodes.add(scanNode);
-        List<ScanNode> scanNodeList = 
selectStmtToScanNodes.computeIfAbsent(selectStmt.getId(), k -> 
Lists.newArrayList());
+        List<ScanNode> scanNodeList = 
selectStmtToScanNodes.computeIfAbsent(selectStmt.getAnalyzer(), k -> 
Lists.newArrayList());
         scanNodeList.add(scanNode);
         return scanNode;
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org