diff --git a/internal/app/app.go b/internal/app/app.go index c47f4b80..33d32df9 100644 --- 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)