fix

Signed-off-by: srlch <[email protected]>
srlch · Jan 17, 2025 · 429e5b9 · 429e5b9
1 parent 2b70543
commit 429e5b9
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/fe/fe-core/src/main/java/com/starrocks/lake/snapshot/ClusterSnapshotCheckpointScheduler.java b/fe/fe-core/src/main/java/com/starrocks/lake/snapshot/ClusterSnapshotCheckpointScheduler.java
@@ -51,6 +51,9 @@ protected void runAfterCatalogReady() {
 
         // skip first run when the scheduler start
         if (firstRun) {
+            // if leader change and the last cluster snapshot job has not been finished/error
+            // make the state as error, becase the job can not be continued in new leader.
+            GlobalStateMgr.getCurrentState().getClusterSnapshotMgr().resetLastUnFinishedAutomatedSnapshotJob();
             firstRun = false;
             return;
         }

diff --git a/fe/fe-core/src/main/java/com/starrocks/server/GlobalStateMgr.java b/fe/fe-core/src/main/java/com/starrocks/server/GlobalStateMgr.java
@@ -1327,12 +1327,6 @@ private void transferToLeader() {
         createBuiltinStorageVolume();
         resourceGroupMgr.createBuiltinResourceGroupsIfNotExist();
         keyMgr.initDefaultMasterKey();
-
-        // if leader change and the last cluster snapshot job has not been finished/error
-        // make the state as error, becase the job can not be continued in new leader.
-        if (clusterSnapshotMgr != null) {
-            clusterSnapshotMgr.resetLastUnFinishedAutomatedSnapshotJob();
-        }
     }
 
     public void setFrontendNodeType(FrontendNodeType newType) {