Merge pull request volcano-sh#39 from volcano-sh/bug/fix_queue_error

Author: Klaus Ma

pkg/apis/batch/v1alpha1/job.go

@@ -60,6 +60,9 @@ type JobSpec struct {
 	// Specifies the default lifecycle of tasks
 	// +optional
 	Policies []LifecyclePolicy `json:"policies,omitempty" protobuf:"bytes,6,opt,name=policies"`
+
+	//Specifies the queue that will be used in the scheduler, "default" queue is used this leaves empty.
+	Queue string `json:"queue,omitempty" protobuf:"bytes,7,opt,name=queue"`
 }
 
 // VolumeSpec defines the specification of Volume, e.g. PVC

pkg/controllers/job/job_controller_actions.go

@@ -450,6 +450,7 @@ func (cc *Controller) createPodGroupIfNotExist(job *vkv1.Job) error {
 			},
 			Spec: kbv1.PodGroupSpec{
 				MinMember: job.Spec.MinAvailable,
+				Queue:     job.Spec.Queue,
 			},
 		}
 

test/e2e/util.go

@@ -329,6 +329,7 @@ func createJobInner(context *context, jobSpec *jobSpec) (*vkv1.Job, error) {
 		},
 		Spec: vkv1.JobSpec{
 			Policies: jobSpec.policies,
+			Queue:    jobSpec.queue,
 		},
 	}