diff --git a/engine/jobmaster/dm/metadata/job.go b/engine/jobmaster/dm/metadata/job.go index bc2e11a33f2..d78f22dda91 100644 --- a/engine/jobmaster/dm/metadata/job.go +++ b/engine/jobmaster/dm/metadata/job.go @@ -222,6 +222,7 @@ func (jobStore *JobStore) UpdateConfig(ctx context.Context, jobCfg *config.JobCf // task stage will not be updated. if oldTask, ok := oldJob.Tasks[taskID]; ok { newTask.Stage = oldTask.Stage + newTask.StageUpdatedTime = oldTask.StageUpdatedTime } }