diff --git a/pkg/querier/worker/frontend_processor.go b/pkg/querier/worker/frontend_processor.go index 47b74ee3874..52029b7e44a 100644 --- a/pkg/querier/worker/frontend_processor.go +++ b/pkg/querier/worker/frontend_processor.go @@ -88,6 +88,7 @@ func (fp *frontendProcessor) processQueriesOnSingleStream(workerCtx context.Cont if !grpcutil.IsCanceled(err) { level.Error(fp.log).Log("msg", "error processing requests", "address", address, "err", err) backoff.Wait() + continue } }