This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch fix_restart_confignode in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 2f0173894d7c96b8a5f935dca6c03d86a127e24e Author: OneSizeFitQuorum <[email protected]> AuthorDate: Tue Aug 1 13:38:14 2023 +0800 fix npe casue by setDataAllotMap Signed-off-by: OneSizeFitQuorum <[email protected]> --- .../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();
