diff --git a/pkg/jobs/jobs.go b/pkg/jobs/jobs.go index 44532cbb62be..a5b90845a50f 100644 --- a/pkg/jobs/jobs.go +++ b/pkg/jobs/jobs.go @@ -928,10 +928,6 @@ func (sj *StartableJob) Start(ctx context.Context) (err error) { return fmt.Errorf("cannot resume %T job which is not committed", sj.resumer) } - if err := sj.started(ctx, nil /* txn */); err != nil { - return err - } - if err := sj.registry.stopper.RunAsyncTask(ctx, sj.taskName(), func(ctx context.Context) { sj.execErr = sj.registry.runJob(sj.resumerCtx, sj.resumer, sj.Job, StatusRunning, sj.taskName()) close(sj.execDone)