Merge pull request #1023 from xiaoanyunfei/bugfix/victims_preemptee

fix duplicate preemptee in victims
volcano-sh · Sep 3, 2020 · dace5c5 · dace5c5
2 parents 6523007 + 15690cc
commit dace5c5
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