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 index 03b0f6ebcdb7e4..76f4fe11f13da3 100644 --- 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; }