diff --git a/pkg/ddl/ddl_worker.go b/pkg/ddl/ddl_worker.go index d3dea0240c..948b649609 100644 --- a/pkg/ddl/ddl_worker.go +++ b/pkg/ddl/ddl_worker.go @@ -946,6 +946,7 @@ func (w *worker) HandleDDLJobTable(d *ddlCtx, job *model.Job) (int64, error) { } if err = w.checkOwnerBeforeCommit(); err != nil { + d.unlockSchemaVersion(job.ID) return 0, err }