mysqld: check for correct return value from WAIT_FOR_EXECUTED_GTID_SET

Signed-off-by: deepthi <[email protected]>
vitessio · Dec 9, 2023 · 7624ff0 · 7624ff0
1 parent ab1ba2e
commit 7624ff0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/go/vt/mysqlctl/replication.go b/go/vt/mysqlctl/replication.go
@@ -377,7 +377,7 @@ func (mysqld *Mysqld) WaitSourcePos(ctx context.Context, targetPos replication.P
 	if result.IsNull() {
 		return fmt.Errorf("%v(%v) failed: replication is probably stopped", waitCommandName, query)
 	}
-	if result.ToString() == "-1" {
+	if result.ToString() == "1" {
 		return fmt.Errorf("timed out waiting for position %v", targetPos)
 	}
 	return nil