diff --git a/go/logic/throttler.go b/go/logic/throttler.go index b7739f8..849f40f 100644 --- a/go/logic/throttler.go +++ b/go/logic/throttler.go @@ -252,8 +252,7 @@ func (this *Throttler) collectControlReplicasLag() { ticker := time.NewTicker(100 * time.Millisecond) defer ticker.Stop() - for { - <-ticker.C + for range ticker.C { if atomic.LoadInt64(&this.finishedMigrating) > 0 { return }