ddl: unlock schema version mutex properly (#50327)

close pingcap/tidb#50309
2024-01-11 18:15:32 +08:00
parent 22d2f6ddcf
commit e35bb6ded9
1 changed files with 1 additions and 0 deletions
--- 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
 	}