This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
commit ad359682366e7ac9124552cb53dea88a7c3d6d19
Author: Calvin Kirs <k...@apache.org>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
