fixup

w41ter · Nov 4, 2024 · cea1bf0 · cea1bf0
1 parent ac2974f
commit cea1bf0
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java b/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java
@@ -131,7 +131,7 @@ public class RestoreJob extends AbstractJob implements GsonPostProcessable {
     public enum RestoreJobState {
         PENDING, // Job is newly created. Check and prepare meta in catalog. Create replica if necessary.
                  // Waiting for replica creation finished synchronously, then sending snapshot tasks.
-                 // then transfer to PENDING.
+                 // then transfer to CREATING.
         CREATING, // Creating replica on BE. Transfer to SNAPSHOTING after all replicas created.
         SNAPSHOTING, // Waiting for snapshot finished. Than transfer to DOWNLOAD.
         DOWNLOAD, // Send download tasks.
@@ -445,8 +445,8 @@ public synchronized void run() {
         checkIfNeedCancel();
 
         if (status.ok()) {
-            if (state != RestoreJobState.PENDING && label.equals(
-                    DebugPointUtil.getDebugParamOrDefault("FE.PAUSE_NON_PENDING_RESTORE_JOB", ""))) {
+            if ((state != RestoreJobState.PENDING || state != RestoreJobState.CREATING)
+                    && label.equals(DebugPointUtil.getDebugParamOrDefault("FE.PAUSE_NON_PENDING_RESTORE_JOB", ""))) {
                 LOG.info("pause restore job by debug point: {}", this);
                 return;
             }