From b2f24cc8c8933e7bf3e33783345988d3ddebabec Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 28 May 2020 19:51:30 +0800 Subject: [PATCH] update fair --- src/scheduler_fair.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 2d8859a..938e7c8 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -396,10 +396,8 @@ func (scheduler *SchedulerFair) UpdateQuota() { availableCPU -= (requests[queue].CPU * base) / requests[queue].NumberGPU quota.Memory += ((requests[queue].Memory * base) / requests[queue].NumberGPU) / 1000 } - /* left more and more resource */ - if per != 0 { - availableGPU = availableGPU % per - } + /* avoid resource leak, and reserve full */ + availableGPU = availableGPU % 1000 if availableGPU > 0 { for _, queue := range candidates { quota := scheduler.queuesQuota[queue]