You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yo...@apache.org on 2023/08/06 13:47:41 UTC
[iotdb] 01/01: Finish
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a commit to branch Optimize-load-balance-event
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 16d598232a0816fe492eb73f14038599e9cebbed
Author: YongzaoDan <53...@qq.com>
AuthorDate: Sun Aug 6 21:47:25 2023 +0800
Finish
---
.../iotdb/confignode/manager/load/service/StatisticsService.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/StatisticsService.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/StatisticsService.java
index 01f8fab8934..feb01ee04ef 100644
--- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/StatisticsService.java
+++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/StatisticsService.java
@@ -147,7 +147,9 @@ public class StatisticsService implements IClusterStatusSubscriber {
// Map<RegionGroupId, Pair<old priority, new priority>>
Map<TConsensusGroupId, Pair<TRegionReplicaSet, TRegionReplicaSet>>
differentRegionPriorityMap = routeBalancer.balanceRegionPriority();
- eventBus.post(new RouteChangeEvent(differentRegionLeaderMap, differentRegionPriorityMap));
+ if (!differentRegionLeaderMap.isEmpty() || !differentRegionPriorityMap.isEmpty()) {
+ eventBus.post(new RouteChangeEvent(differentRegionLeaderMap, differentRegionPriorityMap));
+ }
}
if (isNeedBroadcast) {