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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
