This is an automated email from the ASF dual-hosted git repository. shuwenwei pushed a commit to branch parallelDispatch in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 55cbf5f822d6e9aa000da75c01bbf3ed166dce7c Author: shuwenwei <[email protected]> AuthorDate: Fri May 23 16:38:37 2025 +0800 fix for tree model --- .../plan/planner/distribution/SimpleFragmentParallelPlanner.java | 1 + .../org/apache/iotdb/db/queryengine/plan/planner/plan/PlanFragment.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/SimpleFragmentParallelPlanner.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/SimpleFragmentParallelPlanner.java index 2cadce4e51a..8e901f3a067 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/SimpleFragmentParallelPlanner.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/SimpleFragmentParallelPlanner.java @@ -157,6 +157,7 @@ public class SimpleFragmentParallelPlanner extends AbstractFragmentParallelPlann fragmentInstance.getFragment().generateTypeProvider(queryContext.getTypeProvider()); } instanceMap.putIfAbsent(fragment.getId(), fragmentInstance); + fragment.setIndexInFragmentInstanceList(fragmentInstanceList.size()); fragmentInstanceList.add(fragmentInstance); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/PlanFragment.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/PlanFragment.java index 448e8e2fda0..a178c5c1f6c 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/PlanFragment.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/PlanFragment.java @@ -58,7 +58,7 @@ public class PlanFragment { // indicate whether this PlanFragment is the root of the whole Fragment-Plan-Tree or not private boolean isRoot; - private int indexInFragmentInstanceList; + private int indexInFragmentInstanceList = -1; public PlanFragment(PlanFragmentId id, PlanNode planNodeTree) { this.id = id;
