diff --git a/pkg/querier/tail.go b/pkg/querier/tail.go index 56c5ef8f7e5e..87dba6bae09a 100644 --- a/pkg/querier/tail.go +++ b/pkg/querier/tail.go @@ -87,8 +87,7 @@ func (t *Tailer) loop() { droppedEntries := make([]loghttp.DroppedEntry, 0) - stopped := t.stopped.Load() - for !stopped { + for !t.stopped.Load() { select { case <-checkConnectionTicker.C: // Try to reconnect dropped ingesters and connect to new ingesters