Fix IoTConsensus safe deleted index (apache#14883)

* done

* move

Author: liyuheng55555

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

@@ -207,6 +207,11 @@ private void initAndRecover() throws IOException {
               consensusGroupId ->
                   resetPeerListWithoutThrow.accept(consensusGroupId, Collections.emptyList()));
     }
+    // Since the underlying wal does not persist safelyDeletedSearchIndex, IoTConsensus needs to
+    // update wal with its syncIndex recovered from the consensus layer when initializing.
+    // This prevents wal from being piled up if the safelyDeletedSearchIndex is not updated after
+    // the restart and Leader migration occurs
+    stateMachineMap.values().forEach(IoTConsensusServerImpl::checkAndUpdateSafeDeletedSearchIndex);
     stateMachineMap.values().forEach(IoTConsensusServerImpl::start);
   }
 

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

@@ -150,11 +150,6 @@ public IoTConsensusServerImpl(
     this.searchIndex = new AtomicLong(consensusReqReader.getCurrentSearchIndex());
     this.ioTConsensusServerMetrics = new IoTConsensusServerMetrics(this);
     this.logDispatcher = new LogDispatcher(this, clientManager);
-    // Since the underlying wal does not persist safelyDeletedSearchIndex, IoTConsensus needs to
-    // update wal with its syncIndex recovered from the consensus layer when initializing.
-    // This prevents wal from being piled up if the safelyDeletedSearchIndex is not updated after
-    // the restart and Leader migration occurs
-    checkAndUpdateSafeDeletedSearchIndex();
     // see message in logs for details
     checkAndUpdateSearchIndex();
   }
@@ -839,8 +834,11 @@ public void cleanupLocalSnapshot() {
    * If there is only one replica, set it to Long.MAX_VALUE.、 If there are multiple replicas, get
    * the latest SafelyDeletedSearchIndex again. This enables wal to be deleted in a timely manner.
    */
-  public void checkAndUpdateSafeDeletedSearchIndex() {
-    if (configuration.size() == 1) {
+  void checkAndUpdateSafeDeletedSearchIndex() {
+    if (configuration.isEmpty()) {
+      logger.error(
+          "Configuration is empty, which is unexpected. Safe deleted search index won't be updated this time.");
+    } else if (configuration.size() == 1) {
       consensusReqReader.setSafelyDeletedSearchIndex(Long.MAX_VALUE);
     } else {
       consensusReqReader.setSafelyDeletedSearchIndex(getMinFlushedSyncIndex());