fix: split brain due to outdated information on the source

yandex · Mar 11, 2024 · 5af95a6 · 5af95a6
1 parent e4dc375
commit 5af95a6
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/internal/app/app.go b/internal/app/app.go
@@ -2091,6 +2091,16 @@ func (app *App) getClusterStateFromDB() map[string]*NodeState {
 		return app.getNodeState(host), nil
 	}
 	clusterState, _ := getNodeStatesInParallel(hosts, getter)
+
+	// it is necessary to get an up-to-date gtid from the source
+	for host, state := range clusterState {
+		if !state.IsMaster {
+			continue
+		}
+		clusterState[host] = app.getNodeState(host)
+		break
+	}
+
 	return clusterState
 }