Skip to content

Commit 5b04de0

Browse files
JNSimbaYour Name
authored andcommitted
[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.
1 parent 02e74ce commit 5b04de0

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)