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

ycycse pushed a commit to branch RefactorEA
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/RefactorEA by this push:
     new c889410f049 set default region for EAN in tree model
c889410f049 is described below

commit c889410f04966cb39eeba49b513ae80a7a400604
Author: YangCaiyin <[email protected]>
AuthorDate: Tue Nov 26 17:14:39 2024 +0800

    set default region for EAN in tree model
---
 .../db/queryengine/plan/planner/distribution/ExchangeNodeAdder.java   | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/ExchangeNodeAdder.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/ExchangeNodeAdder.java
index cc683437198..4fee3052a54 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/ExchangeNodeAdder.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/ExchangeNodeAdder.java
@@ -421,6 +421,10 @@ public class ExchangeNodeAdder extends 
PlanVisitor<PlanNode, NodeGroupContext> {
     newNode.setChild(exchangeNode);
 
     context.hasExchangeNode = true;
+    context.putNodeDistribution(
+        newNode.getPlanNodeId(),
+        new NodeDistribution(
+            NodeDistributionType.DIFFERENT_FROM_ALL_CHILDREN, 
DataPartition.NOT_ASSIGNED));
     return newNode;
   }
 

Reply via email to