diff --git a/deployment/kube-batch/Chart.yaml b/deployment/kube-batch/Chart.yaml index 69bc7f854..07a785ca3 100644 --- a/deployment/kube-batch/Chart.yaml +++ b/deployment/kube-batch/Chart.yaml @@ -1,4 +1,4 @@ apiVersion: v1alpha1 description: The batch scheduler of Kubernetes name: kube-batch -version: 0.2.0 +version: 0.3.0 diff --git a/pkg/scheduler/actions/allocate/allocate.go b/pkg/scheduler/actions/allocate/allocate.go index 018409851..0b897186c 100644 --- 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.