MaxConcurrentRequestsint`yaml:"-"`// Must be same as passed to PromQL Engine.
MaxConcurrentRequestsint`yaml:"-"`// Must be same as passed to LogQL Engine.
QuerierIDstring`yaml:"id"`
@ -260,7 +260,7 @@ func (w *querierWorker) resetConcurrency() {
// If concurrency is 0 then MaxConcurrentRequests is less than the total number of
// frontends/schedulers. In order to prevent accidentally starving a frontend or scheduler we are just going to
// always connect once to every target. This is dangerous b/c we may start exceeding PromQL
// always connect once to every target. This is dangerous b/c we may start exceeding LogQL
// max concurrency.
ifconcurrency==0{
concurrency=1
@ -272,7 +272,7 @@ func (w *querierWorker) resetConcurrency() {
}
iftotalConcurrency>w.cfg.MaxConcurrentRequests{
level.Warn(w.logger).Log("msg","total worker concurrency is greater than promql max concurrency. Queries may be queued in the querier which reduces QOS")
level.Warn(w.logger).Log("msg","total worker concurrency is greater than logql max concurrency. Queries may be queued in the querier which reduces QOS")