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