diff --git a/pkg/ingester/tailer.go b/pkg/ingester/tailer.go index 67d36f6a50e2..35c2cb579d60 100644 --- a/pkg/ingester/tailer.go +++ b/pkg/ingester/tailer.go @@ -136,7 +136,6 @@ func (t *tailer) send(stream logproto.Stream, lbs labels.Labels) { t.dropStream(*s) } } - return } func (t *tailer) processStream(stream logproto.Stream, lbs labels.Labels) []*logproto.Stream {