fix duplicate preemptee in victims

Signed-off-by: xiaofei.sun <sunxiaofei@kuaishou.com>
volcano-sh · Sep 2, 2020 · 15690cc · 15690cc
1 parent ad3a8a1
commit 15690cc
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/scheduler/plugins/drf/drf.go b/pkg/scheduler/plugins/drf/drf.go
@@ -163,6 +163,7 @@ func (drf *drfPlugin) OnSessionOpen(ssn *framework.Session) {
 				// have the higher weighted share after preemption.
 				if lNsShareWeighted < rNsShareWeighted {
 					addVictim(preemptee)
+					continue
 				}
 				if lNsShareWeighted-rNsShareWeighted > shareDelta {
 					continue