Only reset SchemaState when binlog.SchemaState is delete only

pingcap · Nov 20, 2019 · 99c6ed1 · 99c6ed1
1 parent 80b32c0
commit 99c6ed1
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/drainer/collector.go b/drainer/collector.go
@@ -286,7 +286,9 @@ func (c *Collector) syncBinlog(item *binlogItem) error {
 		if skipJob(job) {
 			return nil
 		}
-		job.SchemaState = model.SchemaState(binlog.DdlSchemaState)
+		if model.SchemaState(binlog.DdlSchemaState) == model.StateDeleteOnly {
+			job.SchemaState = model.StateDeleteOnly
+		}
 		item.SetJob(job)
 		ddlJobsCounter.Add(float64(1))
 	}