fix

apache · Jun 12, 2024 · 7b052d4 · 7b052d4
1 parent a1567ea
commit 7b052d4
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/...org/apache/celeborn/service/deploy/master/clustermeta/ha/CelebornStateMachineStorage.java b/...org/apache/celeborn/service/deploy/master/clustermeta/ha/CelebornStateMachineStorage.java
@@ -24,7 +24,12 @@
 import java.nio.file.DirectoryStream;
 import java.nio.file.Files;
 import java.nio.file.Path;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Comparator;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Objects;
+import java.util.Optional;
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
@@ -206,7 +211,7 @@ public File getTmpDir() {
     return tmpDir;
   }
 
-  public void refreshLatestSnapshot() {
+  public void loadLatestSnapshot() {
     final File dir = stateMachineDir;
     if (dir == null) {
       return;

diff --git a/.../src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java b/.../src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java
@@ -98,7 +98,7 @@ public void initialize(RaftServer server, RaftGroupId id, RaftStorage raftStorag
   public void reinitialize() throws IOException {
     LOG.info("Reinitializing state machine.");
     getLifeCycle().compareAndTransition(PAUSED, STARTING);
-    storage.refreshLatestSnapshot();
+    storage.loadLatestSnapshot();
     loadSnapshot(storage.getLatestSnapshot());
     getLifeCycle().compareAndTransition(STARTING, RUNNING);
   }