Do not psync replicas if new primary has not paused replication

yandex · Sep 5, 2024 · 9e0e92f · 9e0e92f
1 parent 3177fb4
commit 9e0e92f
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/internal/app/switchover.go b/internal/app/switchover.go
@@ -360,6 +360,10 @@ func (app *App) performSwitchover(shardState map[string]*HostState, activeNodes
 				if host == newMaster {
 					continue
 				}
+				if !shardState[newMaster].IsReplPaused {
+					app.logger.Warn(fmt.Sprintf("Unable to psync %s before promote: replication on new master is not paused", host))
+					continue
+				}
 				if isPartialSyncPossible(shardState[host], shardState[newMaster]) {
 					psyncNodes = append(psyncNodes, host)
 				}