Skip to content

Commit

Permalink
[Fix](Job)Replaying logs should not modify the original information o…
Browse files Browse the repository at this point in the history
…f the job
  • Loading branch information
CalvinKirs committed Sep 6, 2024
1 parent 9faecb9 commit 8a138d4
Showing 1 changed file with 2 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -31,8 +31,6 @@
import org.apache.doris.common.FeConstants;
import org.apache.doris.common.LabelAlreadyUsedException;
import org.apache.doris.common.io.Text;
import org.apache.doris.common.util.LogBuilder;
import org.apache.doris.common.util.LogKey;
import org.apache.doris.common.util.TimeUtils;
import org.apache.doris.datasource.InternalCatalog;
import org.apache.doris.job.base.AbstractJob;
Expand Down Expand Up @@ -647,12 +645,8 @@ public void onUnRegister() throws JobException {

@Override
public void onReplayCreate() throws JobException {
JobExecutionConfiguration jobConfig = new JobExecutionConfiguration();
jobConfig.setExecuteType(JobExecuteType.INSTANT);
setJobConfig(jobConfig);
onRegister();
checkJobParams();
log.info(new LogBuilder(LogKey.LOAD_JOB, getJobId()).add("msg", "replay create load job").build());
super.onReplayCreate();
}

@Override
Expand All @@ -662,8 +656,7 @@ public void onReplayEnd(AbstractJob<?, Map<Object, Object>> replayJob) throws Jo
}
InsertJob insertJob = (InsertJob) replayJob;
unprotectReadEndOperation(insertJob);
log.info(new LogBuilder(LogKey.LOAD_JOB,
insertJob.getJobId()).add("operation", insertJob).add("msg", "replay end load job").build());
super.onReplayEnd(replayJob);
}

public int getProgress() {
Expand Down

0 comments on commit 8a138d4

Please sign in to comment.