You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2023/08/01 06:25:12 UTC
[iotdb] branch master updated: Fix confignode restart Error (#10752)
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 53b00d46c65 Fix confignode restart Error (#10752)
53b00d46c65 is described below
commit 53b00d46c6538cffc21cb3662c75771835d6d9f4
Author: Potato <ta...@apache.org>
AuthorDate: Tue Aug 1 14:25:06 2023 +0800
Fix confignode restart Error (#10752)
fix npe casue by setDataAllotMap
Signed-off-by: OneSizeFitQuorum <ta...@apache.org>
---
.../manager/load/balancer/partition/DataPartitionPolicyTable.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/DataPartitionPolicyTable.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/DataPartitionPolicyTable.java
index ba367792448..ed297abf4d7 100644
--- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/DataPartitionPolicyTable.java
+++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/partition/DataPartitionPolicyTable.java
@@ -120,6 +120,10 @@ public class DataPartitionPolicyTable {
/** Only use this interface when init PartitionBalancer. */
public void setDataAllotMap(Map<TSeriesPartitionSlot, TConsensusGroupId> dataAllotMap) {
+ if (seriesPartitionSlotCounter.size() == 0) {
+ // No need to re-balance when there is no DataRegionGroup
+ return;
+ }
try {
dataAllotTableLock.lock();
int mu = SERIES_SLOT_NUM / seriesPartitionSlotCounter.size();