Skip to content

Commit dfde852

Browse files
committed
Floor portion to 0
1 parent ee835bc commit dfde852

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

pkg/scheduler/plugins/proportion/resource_division/resource_division.go

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -189,11 +189,17 @@ func divideUpToFairShare(totalResourceAmount, kValue float64, queues map[common_
189189
// We assume that usage is normalized to usage/clusterCapacity
190190
nUsage := share.GetUsage()
191191

192-
portion := nWeight + kValue*(nWeight-nUsage)
192+
// Floor portion to 0 if it's negative
193+
portion := math.Max(0, nWeight+kValue*(nWeight-nUsage))
194+
193195
portions[queue.UID] = portion
194196
totalPortions += portion
195197
}
196198

199+
if totalPortions == 0 {
200+
break
201+
}
202+
197203
for _, queue := range queues {
198204
requested := getRemainingRequested(queue, resourceName)
199205
if requested == 0 {

0 commit comments

Comments
 (0)