From 40c6f180f496243b5c387fcf8c6c432c7a7c0f8e Mon Sep 17 00:00:00 2001 From: Ziyang Wu Date: Wed, 27 Mar 2019 14:05:45 +0800 Subject: [PATCH] Fix wrong caculation for deserved in proportion plugin --- pkg/scheduler/plugins/proportion/proportion.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/pkg/scheduler/plugins/proportion/proportion.go b/pkg/scheduler/plugins/proportion/proportion.go index 4a0c5a6c1..6520690b6 100644 --- a/pkg/scheduler/plugins/proportion/proportion.go +++ b/pkg/scheduler/plugins/proportion/proportion.go @@ -124,7 +124,8 @@ func (pp *proportionPlugin) OnSessionOpen(ssn *framework.Session) { continue } - attr.deserved.Add(remaining.Clone().Multi(float64(attr.weight) / float64(totalWeight))) + queueDeserved := remaining.Clone().Multi(float64(attr.weight) / float64(totalWeight)) + attr.deserved.Add(queueDeserved) if !attr.deserved.LessEqual(attr.request) { attr.deserved = helpers.Min(attr.deserved, attr.request) meet[attr.queueID] = struct{}{} @@ -134,7 +135,7 @@ func (pp *proportionPlugin) OnSessionOpen(ssn *framework.Session) { glog.V(4).Infof("The attributes of queue <%s> in proportion: deserved <%v>, allocate <%v>, request <%v>, share <%0.2f>", attr.name, attr.deserved, attr.allocated, attr.request, attr.share) - deserved.Add(attr.deserved) + deserved.Add(queueDeserved) } remaining.Sub(deserved)