diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/manager/JobManager.java b/fe/fe-core/src/main/java/org/apache/doris/job/manager/JobManager.java
index 45e940ebc3182b..9cc2857a7549dd 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/job/manager/JobManager.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/job/manager/JobManager.java
@@ -224,7 +224,9 @@ public void dropJobInternal(T job, boolean isReplay) throws JobException {
         }
         writeLock();
         try {
-            deleteStreamingJob(job);
+            if (!isReplay) {
+                deleteStreamingJob(job);
+            }
             jobMap.remove(job.getJobId());
             if (isReplay) {
                 job.onReplayEnd(job);