diff --git a/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go b/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go index 4445089da2a..b72a0d500ff 100644 --- a/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go +++ b/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go @@ -709,7 +709,7 @@ func (qs *queueSet) selectQueueLocked() *queue { if queue.requests.Length() != 0 { sMin = math.Min(sMin, queue.virtualStart) sMax = math.Max(sMax, queue.virtualStart) - estimatedWorkInProgress := qs.estimatedServiceTime * float64(queue.requestsExecuting) + estimatedWorkInProgress := qs.estimatedServiceTime * float64(queue.seatsInUse) dsMin = math.Min(dsMin, queue.virtualStart-estimatedWorkInProgress) dsMax = math.Max(dsMax, queue.virtualStart-estimatedWorkInProgress) // the virtual finish time of the oldest request is: