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