diff --git a/example/job.yaml b/example/job.yaml
index 36040abb83..0deb143200 100644
--- a/example/job.yaml
+++ b/example/job.yaml
@@ -4,6 +4,7 @@ metadata:
   name: test-job
 spec:
   minAvailable: 3
+  schedulerName: kube-batch
   policies:
   - event: PodEvicted
     action: RestartJob
@@ -31,4 +32,3 @@ spec:
             requests:
               cpu: "1"
         restartPolicy: OnFailure
-        schedulerName: kube-batch
diff --git a/pkg/controllers/job/job_controller_util.go b/pkg/controllers/job/job_controller_util.go
index 9c8efe4012..51177ff673 100644
--- a/pkg/controllers/job/job_controller_util.go
+++ b/pkg/controllers/job/job_controller_util.go
@@ -71,6 +71,11 @@ func createJobPod(job *vkv1.Job, template *v1.PodTemplateSpec, ix int) *v1.Pod {
 		Spec: templateCopy.Spec,
 	}
 
+	// If no scheduler name in Pod, use scheduler name from Job.
+	if len(pod.Spec.SchedulerName) == 0 {
+		pod.Spec.SchedulerName = job.Spec.SchedulerName
+	}
+
 	if job.Spec.Output != nil {
 		if job.Spec.Output.VolumeClaim == nil {
 			volume := v1.Volume{