This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new 64f7d78c6db branch-4.0: [Fix](streamingjob) Replay mode no need to
clear job information. #59597 (#59617)
64f7d78c6db is described below
commit 64f7d78c6db2ee9fd096ddef0ab23c21766b1d38
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Jan 7 22:11:40 2026 +0800
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]>
---
fe/fe-core/src/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 45e940ebc31..9cc2857a754 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 class JobManager<T extends AbstractJob<?, C>, C>
implements Writable {
}
writeLock();
try {
- deleteStreamingJob(job);
+ if (!isReplay) {
+ deleteStreamingJob(job);
+ }
jobMap.remove(job.getJobId());
if (isReplay) {
job.onReplayEnd(job);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
