database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Fix](Job)Job repaly logic error (#34378)

Browse Source
This commit is contained in:
Calvin Kirs
2024-05-02 14:32:04 +08:00
committed by yiguolei
parent 3fd3dfe16f
commit ad35968236
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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());
}
/**