You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2022/11/16 02:26:15 UTC

[iotdb] branch master updated: [IOTDB-4823] Adjust maxRegionGroupCount failed because StorageGroup doesn't exist (#7984)

This is an automated email from the ASF dual-hosted git repository.

caogaofei 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 37c2792ab8 [IOTDB-4823] Adjust maxRegionGroupCount failed because StorageGroup doesn't exist (#7984)
37c2792ab8 is described below

commit 37c2792ab8c84f62a0fa59ca6d20c2a766bb1078
Author: Itami Sho <42...@users.noreply.github.com>
AuthorDate: Wed Nov 16 10:26:10 2022 +0800

    [IOTDB-4823] Adjust maxRegionGroupCount failed because StorageGroup doesn't exist (#7984)
---
 .../apache/iotdb/confignode/manager/ClusterSchemaManager.java    | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java
index 227305330e..e7377349c2 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java
@@ -141,9 +141,12 @@ public class ClusterSchemaManager {
   }
 
   public TSStatus deleteStorageGroup(DeleteStorageGroupPlan deleteStorageGroupPlan) {
-    // Adjust the maximum RegionGroup number of each StorageGroup
-    adjustMaxRegionGroupCount();
-    return getConsensusManager().write(deleteStorageGroupPlan).getStatus();
+    TSStatus result = getConsensusManager().write(deleteStorageGroupPlan).getStatus();
+    // Adjust the maximum RegionGroup number of each StorageGroup after deleting the storage group
+    if (result.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
+      adjustMaxRegionGroupCount();
+    }
+    return result;
   }
 
   /**