Merge pull request kubernetes-retired#540 from Jeffwan/examine_all_tasks

Examine all pending tasks in a job
kevin-wangzefeng · Jan 7, 2019 · d856cdc · d856cdc
2 parents 67cdb66 + adbbfdc
commit d856cdc
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/pkg/scheduler/actions/allocate/allocate.go b/pkg/scheduler/actions/allocate/allocate.go
@@ -161,10 +161,11 @@ func (alloc *allocateAction) Execute(ssn *framework.Session) {
 
 			if assigned {
 				jobs.Push(job)
+				// Handle one assigned task in each loop.
+				break
 			}
 
-			// Handle one pending task in each loop.
-			break
+			// If current task is not assgined, try to fit all rest tasks.
 		}
 
 		// Added Queue back until no job in Queue.