fix: semi sync does not turn off on the old master (#31)

yandex · Aug 24, 2023 · 0925c46 · 0925c46
1 parent b360470
commit 0925c46
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/app/app.go b/internal/app/app.go
@@ -907,6 +907,7 @@ func (app *App) calcActiveNodesChanges(clusterState map[string]*NodeState, activ
 			if dataLag > app.config.SemiSyncEnableLag {
 				app.logger.Warnf("calc active nodes: %v should become active, but it has data lag %d, delaying...", host, dataLag)
 				dataLagging = append(dataLagging, host)
+				becomeInactive = append(becomeInactive, host)
 			}
 		}
 		becomeActive = filterOut(becomeActive, dataLagging)