From 5b04de0a6b75d4e2c10a0c7b0520d1063f4d7cbc Mon Sep 17 00:00:00 2001 From: wudi Date: Wed, 7 Jan 2026 14:03:09 +0800 Subject: [PATCH] [Fix](streamingjob) Replay mode no need to clear job information. (#59597) ### What problem does this PR solve? Replay mode no need to clear job information. --- .../main/java/org/apache/doris/job/manager/JobManager.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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);