This is an automated email from the ASF dual-hosted git repository.
kirs pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new d71fab8eadd [Fix](Job)Job repaly logic error (#34378)
d71fab8eadd is described below
commit d71fab8eadd867b374cfe9bde8cc4833ca1857d7
Author: Calvin Kirs <[email protected]>
AuthorDate: Thu May 2 14:32:04 2024 +0800
[Fix](Job)Job repaly logic error (#34378)
---
.../src/main/java/org/apache/doris/job/manager/JobManager.java | 5 ++++-
1 file changed, 4 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 4eb333426c4..d8a30a968a6 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
@@ -29,6 +29,8 @@ import org.apache.doris.common.ErrorReport;
import org.apache.doris.common.PatternMatcher;
import org.apache.doris.common.PatternMatcherWrapper;
import org.apache.doris.common.io.Writable;
+import org.apache.doris.common.util.LogBuilder;
+import org.apache.doris.common.util.LogKey;
import org.apache.doris.datasource.InternalCatalog;
import org.apache.doris.job.base.AbstractJob;
import org.apache.doris.job.common.JobStatus;
@@ -265,7 +267,8 @@ public class JobManager<T extends AbstractJob<?, C>, C>
implements Writable {
**/
public void replayUpdateJob(T job) {
jobMap.put(job.getJobId(), job);
- job.logUpdateOperation();
+ log.info(new LogBuilder(LogKey.SCHEDULER_JOB, job.getJobId())
+ .add("msg", "replay update scheduler job").build());
}
/**
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
