Skip to content

Commit 64f7d78

Browse files
branch-4.0: [Fix](streamingjob) Replay mode no need to clear job information. #59597 (#59617)
Cherry-picked from #59597 Co-authored-by: wudi <[email protected]>
1 parent bcb9b08 commit 64f7d78

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

fe/fe-core/src/main/java/org/apache/doris/job/manager/JobManager.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -224,7 +224,9 @@ public void dropJobInternal(T job, boolean isReplay) throws JobException {
224224
}
225225
writeLock();
226226
try {
227-
deleteStreamingJob(job);
227+
if (!isReplay) {
228+
deleteStreamingJob(job);
229+
}
228230
jobMap.remove(job.getJobId());
229231
if (isReplay) {
230232
job.onReplayEnd(job);

0 commit comments

Comments
 (0)