diff --git a/couchbase/rollback_mitigation.go b/couchbase/rollback_mitigation.go index 64e1722..09fe2b5 100644 --- a/couchbase/rollback_mitigation.go +++ b/couchbase/rollback_mitigation.go @@ -220,6 +220,10 @@ func (r *rollbackMitigation) startObserve(groupID int) { } func (r *rollbackMitigation) observeVbUUIDMap() { + if r.failOverUUIDTimer != nil { + return + } + r.failOverUUIDTimer = time.NewTicker(time.Minute) for range r.failOverUUIDTimer.C { r.LoadVbUUIDMap()