[To rel/1.0] fix snapshot init warning (#8226)

consensus/src/main/java/org/apache/iotdb/consensus/ratis/ApplicationStateMachineProxy.java

@@ -61,13 +61,13 @@ public class ApplicationStateMachineProxy extends BaseStateMachine {
 
   public ApplicationStateMachineProxy(IStateMachine stateMachine, RaftGroupId id) {
     applicationStateMachine = stateMachine;
+    groupId = id;
     retryPolicy =
         applicationStateMachine instanceof IStateMachine.RetryPolicy
             ? (IStateMachine.RetryPolicy) applicationStateMachine
             : new IStateMachine.RetryPolicy() {};
-    snapshotStorage = new SnapshotStorage(applicationStateMachine);
+    snapshotStorage = new SnapshotStorage(applicationStateMachine, groupId);
     applicationStateMachine.start();
-    groupId = id;
   }
 
   @Override

consensus/src/main/java/org/apache/iotdb/consensus/ratis/SnapshotStorage.java

@@ -20,6 +20,7 @@ package org.apache.iotdb.consensus.ratis;
 
 import org.apache.iotdb.consensus.IStateMachine;
 
+import org.apache.ratis.protocol.RaftGroupId;
 import org.apache.ratis.server.protocol.TermIndex;
 import org.apache.ratis.server.storage.FileInfo;
 import org.apache.ratis.server.storage.RaftStorage;
@@ -39,7 +40,6 @@ import java.nio.file.Path;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
-import java.util.Optional;
 import java.util.concurrent.locks.ReentrantReadWriteLock;
 
 public class SnapshotStorage implements StateMachineStorage {
@@ -48,17 +48,28 @@ public class SnapshotStorage implements StateMachineStorage {
 
   private final String TMP_PREFIX = ".tmp.";
   private File stateMachineDir;
+  private final RaftGroupId groupId;
+  private File snapshotStorageRoot;
 
   private final ReentrantReadWriteLock snapshotCacheGuard = new ReentrantReadWriteLock();
   private SnapshotInfo currentSnapshot = null;
 
-  public SnapshotStorage(IStateMachine applicationStateMachine) {
+  public SnapshotStorage(IStateMachine applicationStateMachine, RaftGroupId groupId) {
     this.applicationStateMachine = applicationStateMachine;
+    this.groupId = groupId;
   }
 
   @Override
   public void init(RaftStorage raftStorage) throws IOException {
     this.stateMachineDir = raftStorage.getStorageDir().getStateMachineDir();
+    if (getSnapshotDir() != null) {
+      snapshotStorageRoot = new File(getSnapshotDir(), groupId.toString());
+    } else {
+      snapshotStorageRoot = stateMachineDir;
+    }
+    if (!snapshotStorageRoot.exists()) {
+      FileUtils.createDirectories(snapshotStorageRoot);
+    }
     updateSnapshotCache();
   }
 
@@ -168,7 +179,7 @@ public class SnapshotStorage implements StateMachineStorage {
   }
 
   public File getStateMachineDir() {
-    return Optional.ofNullable(getSnapshotDir()).orElse(stateMachineDir);
+    return snapshotStorageRoot;
   }
 
   public File getSnapshotDir(String snapshotMetadata) {