This is an automated email from the ASF dual-hosted git repository. yongzao pushed a commit to branch load-balance-service-optimize in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 997d6d0852d17bf166b4bc2a873394edaea2989b Author: Yongzao <[email protected]> AuthorDate: Mon Apr 13 13:46:15 2026 +0800 finish --- .../org/apache/iotdb/confignode/manager/load/service/EventService.java | 3 +++ .../iotdb/db/queryengine/plan/analyze/ClusterPartitionFetcher.java | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/EventService.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/EventService.java index 52099bdfac3..a02ebff2558 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/EventService.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/EventService.java @@ -115,6 +115,9 @@ public class EventService { currentEventServiceFuture = null; LOGGER.info("Event service is stopped successfully."); } + previousNodeStatisticsMap.clear(); + previousRegionGroupStatisticsMap.clear(); + previousConsensusGroupStatisticsMap.clear(); } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/ClusterPartitionFetcher.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/ClusterPartitionFetcher.java index 2274762341b..bed3e389874 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/ClusterPartitionFetcher.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/ClusterPartitionFetcher.java @@ -523,7 +523,7 @@ public class ClusterPartitionFetcher implements IPartitionFetcher { Map<TSeriesPartitionSlot, TConsensusGroupId> orderedMap = new LinkedHashMap<>(entry1.getValue()); - List<TConsensusGroupId> orderedGroupIds = new ArrayList<>(orderedMap.values()); + List<TConsensusGroupId> orderedGroupIds = new ArrayList<>(new HashSet<>(orderedMap.values())); List<TRegionReplicaSet> regionReplicaSets = partitionCache.getRegionReplicaSet(orderedGroupIds);
