ddl: filter zero job IDs when puting DDLAllSchemaVersionsByJob key (#…

…58991) ref #58992
pingcap · Jan 17, 2025 · 36e8e34 · 36e8e34
1 parent 27bf9c3
commit 36e8e34
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/ddl/schemaver/syncer.go b/pkg/ddl/schemaver/syncer.go
@@ -280,6 +280,10 @@ func (s *etcdSyncer) UpdateSelfVersion(ctx context.Context, jobID int64, version
 	var err error
 	var path string
 	if variable.EnableMDL.Load() {
+		// If jobID is 0, it doesn't need to put into etcd `DDLAllSchemaVersionsByJob` key.
+		if jobID == 0 {
+			return nil
+		}
 		path = fmt.Sprintf("%s/%d/%s", util.DDLAllSchemaVersionsByJob, jobID, s.ddlID)
 		err = util.PutKVToEtcdMono(ctx, s.etcdCli, keyOpDefaultRetryCnt, path, ver)
 	} else {