relay(dm): use binlog name comparison (pingcap#3710) (pingcap#3712)

ti-chi-bot · Jan 13, 2022 · a4330bd · a4330bd
1 parent ef2636a
commit a4330bd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dm/relay/relay.go b/dm/relay/relay.go
@@ -240,7 +240,7 @@ func (r *Relay) process(ctx context.Context) error {
 			}
 		} else {
 			_, metaPos := r.meta.Pos()
-			if neededBinlogName > metaPos.Name {
+			if mysql.CompareBinlogFileName(neededBinlogName, metaPos.Name) > 0 {
 				isRelayMetaOutdated = true
 			}
 		}