fix: Adjust tailer loop criteria so it is actually re-tested (#13906)

1 year ago · dabbfd81ef
parent feee240f46
commit dabbfd81ef
1 changed files with 1 additions and 2 deletions
--- 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