Fix

yandex · Jan 10, 2024 · db17ef4 · db17ef4
1 parent c8ba1bb
commit db17ef4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/app/replication.go b/internal/app/replication.go
@@ -41,7 +41,7 @@ func (app *App) MarkReplicationRunning(node *mysql.Node, channel string) {
 		newGtidSet := gtids.ParseGtidSet(status.GetExecutedGtidSet())
 		oldGtidSet := gtids.ParseGtidSet(replState.LastGTIDExecuted)
 
-		if !isGTIDLessOrEqual(oldGtidSet, newGtidSet) {
+		if !isGTIDLessOrEqual(newGtidSet, oldGtidSet) {
 			delete(app.replRepairState, key)
 		}
 	}