[iotdb] branch master updated: [IOTDB-2919] Delete regions at once besides schedule in 300s interval (#6157)

[qiaojialin]

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

qiaojialin 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 83ef38a2eb [IOTDB-2919] Delete regions at once besides schedule in 
300s interval (#6157)
83ef38a2eb is described below

commit 83ef38a2eb50203538bd8e0318c76749d21c484d
Author: cmlmakahts <82880298+cmlmaka...@users.noreply.github.com>
AuthorDate: Sat Jun 4 16:06:15 2022 +0800

    [IOTDB-2919] Delete regions at once besides schedule in 300s interval 
(#6157)
---
 .../main/java/org/apache/iotdb/confignode/manager/PartitionManager.java | 2 +-
 .../main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java | 2 ++
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/confignode/src/main/java/org/apache/iotdb/confignode/manager/PartitionManager.java
 
b/confignode/src/main/java/org/apache/iotdb/confignode/manager/PartitionManager.java
index c97c4b66bf..638f78acdf 100644
--- 
a/confignode/src/main/java/org/apache/iotdb/confignode/manager/PartitionManager.java
+++ 
b/confignode/src/main/java/org/apache/iotdb/confignode/manager/PartitionManager.java
@@ -402,7 +402,7 @@ public class PartitionManager {
    * Called by {@link PartitionManager#regionCleaner} Delete regions of 
logical deleted storage
    * groups periodically.
    */
-  private void clearDeletedRegions() {
+  public void clearDeletedRegions() {
     if (getConsensusManager().isLeader()) {
       final Set<TRegionReplicaSet> deletedRegionSet = 
partitionInfo.getDeletedRegionSet();
       if (!deletedRegionSet.isEmpty()) {
diff --git 
a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java
 
b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java
index 30c776f4a0..97619cce6c 100644
--- 
a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java
+++ 
b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java
@@ -96,6 +96,8 @@ public class ProcedureManager {
     }
     List<TSStatus> procedureStatus = new ArrayList<>();
     boolean isSucceed = getProcedureStatus(this.executor, procIdList, 
procedureStatus);
+    // clear the previously deleted regions
+    getConfigManager().getPartitionManager().clearDeletedRegions();
     if (isSucceed) {
       return StatusUtils.OK;
     } else {