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 <[email protected]>
AuthorDate: Tue Aug 1 14:25:06 2023 +0800
Fix confignode restart Error (#10752)
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();