From 415444466ea289e46f0495caa60d8e19df79645c Mon Sep 17 00:00:00 2001 From: Armon Dadgar Date: Tue, 22 Sep 2015 22:24:07 -0700 Subject: [PATCH] scheduler: job anti-affinity score should record as negative --- scheduler/rank.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/scheduler/rank.go b/scheduler/rank.go index 7a64186a6..1677187ad 100644 --- a/scheduler/rank.go +++ b/scheduler/rank.go @@ -289,8 +289,8 @@ func (iter *JobAntiAffinityIterator) Next() *RankedNode { // Apply a penalty if there are collisions if collisions > 0 { - scorePenalty := float64(collisions) * iter.penalty - option.Score -= scorePenalty + scorePenalty := -1 * float64(collisions) * iter.penalty + option.Score += scorePenalty iter.ctx.Metrics().ScoreNode(option.Node, "job-anti-affinity", scorePenalty) } return option