Clean up local snapshot after add region peer

iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensus.java

@@ -324,9 +324,13 @@ public void addRemotePeer(ConsensusGroupId groupId, Peer peer) throws ConsensusE
       logger.info("[IoTConsensus] activate new peer...");
       impl.activePeer(peer);
 
-      // step 7: spot clean
-      logger.info("[IoTConsensus] do spot clean...");
-      doSpotClean(peer, impl);
+      // step 7: notify remote peer to clean up transferred snapshot
+      logger.info("[IoTConsensus] clean up remote snapshot...");
+      try {
+        impl.cleanupRemoteSnapshot(peer);
+      } catch (ConsensusGroupModifyPeerException e) {
+        logger.warn("[IoTConsensus] failed to cleanup remote snapshot", e);
+      }
       KillPoint.setKillPoint(DataNodeKillPoints.COORDINATOR_ADD_PEER_DONE);
 
     } catch (ConsensusGroupModifyPeerException e) {
@@ -343,14 +347,8 @@ public void addRemotePeer(ConsensusGroupId groupId, Peer peer) throws ConsensusE
       throw new ConsensusException(e);
     } finally {
       impl.checkAndUnlockSafeDeletedSearchIndex();
-    }
-  }
-
-  private void doSpotClean(Peer peer, IoTConsensusServerImpl impl) {
-    try {
-      impl.cleanupRemoteSnapshot(peer);
-    } catch (ConsensusGroupModifyPeerException e) {
-      logger.warn("[IoTConsensus] failed to cleanup remote snapshot", e);
+      logger.info("[IoTConsensus] clean up local snapshot...");
+      impl.cleanupLocalSnapshot();
     }
   }
 

iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java

@@ -874,15 +874,25 @@ public void cleanupRemoteSnapshot(Peer targetPeer) throws ConsensusGroupModifyPe
     }
   }
 
-  public void cleanupTransferredSnapshot(String snapshotId)
-      throws ConsensusGroupModifyPeerException {
+  public void cleanupSnapshot(String snapshotId) throws ConsensusGroupModifyPeerException {
     File snapshotDir = new File(storageDir, snapshotId);
     if (snapshotDir.exists()) {
       try {
         FileUtils.deleteDirectory(snapshotDir);
       } catch (IOException e) {
         throw new ConsensusGroupModifyPeerException(e);
       }
+    } else {
+      logger.info("File not exist: {}", snapshotDir);
+    }
+  }
+
+  public void cleanupLocalSnapshot() {
+    try {
+      cleanupSnapshot(newSnapshotDirName);
+    } catch (ConsensusGroupModifyPeerException e) {
+      logger.warn(
+          "Cleanup local snapshot fail. You may manually delete {}.", newSnapshotDirName, e);
     }
   }
 

iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/service/IoTConsensusRPCServiceProcessor.java

@@ -328,7 +328,7 @@ public void cleanupTransferredSnapshot(
     }
     TSStatus responseStatus;
     try {
-      impl.cleanupTransferredSnapshot(req.snapshotId);
+      impl.cleanupSnapshot(req.snapshotId);
       responseStatus = new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());
     } catch (ConsensusGroupModifyPeerException e) {
       LOGGER.error("failed to cleanup transferred snapshot {}", req.snapshotId, e);