commit | 6e4863bfb51b3c853ee47c09c9772ebe334ef8e4 | [log] [tgz] |
---|---|---|
author | Yongzao <yongzao@apache.org> | Tue Apr 16 15:58:22 2024 +0800 |
committer | GitHub <noreply@github.com> | Tue Apr 16 15:58:22 2024 +0800 |
tree | b4193ee1164328cdf897e05868c3f787c1b0d62a | |
parent | 89ebd32b1be59be10aeb7ad4853f4f280fdd1a51 [diff] |
Fix auto leader balance for Ratis protocol judgement bug (#12350)
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/RouteBalancer.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/RouteBalancer.java index 25b3fc3..dae72da 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/RouteBalancer.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/RouteBalancer.java
@@ -175,7 +175,7 @@ (regionGroupId, newLeaderId) -> { if (ConsensusFactory.RATIS_CONSENSUS.equals(consensusProtocolClass) && currentTime - lastFailedTimeForLeaderBalance.getOrDefault(regionGroupId, 0L) - > BALANCE_RATIS_LEADER_FAILED_INTERVAL) { + <= BALANCE_RATIS_LEADER_FAILED_INTERVAL) { return; }