diff --git a/pkg/limits/frontend/ring.go b/pkg/limits/frontend/ring.go index eb6dab0534..3bf22c1536 100644 --- a/pkg/limits/frontend/ring.go +++ b/pkg/limits/frontend/ring.go @@ -128,7 +128,7 @@ type zonePartitionConsumersResult struct { // in the replication set. If a zone has no active partition consumers, the // zone will still be returned but its partition consumers will be nil. // If ZoneAwarenessEnabled is false, it returns all partition consumers under -// a psuedo-zone (""). +// a pseudo-zone (""). func (g *RingStreamUsageGatherer) getZoneAwarePartitionConsumers(ctx context.Context, instances []ring.InstanceDesc) (map[string]map[int32]string, error) { zoneDescs := make(map[string][]ring.InstanceDesc) for _, instance := range instances { diff --git a/pkg/querier/queryrange/limits.go b/pkg/querier/queryrange/limits.go index 64e89dac74..5b0cd9610b 100644 --- a/pkg/querier/queryrange/limits.go +++ b/pkg/querier/queryrange/limits.go @@ -696,7 +696,7 @@ func WeightedParallelism( regPart := int(otherDur) * regMaxQueryParallelism / totalDur if combined := regPart + tsdbPart; combined > 0 { - return int(combined) + return combined } // As long as the actual config is not zero,