diff --git a/pkg/controller/sparkapplication/job.go b/pkg/controller/sparkapplication/job.go
index 51bb2259..21bac91a 100644
--- a/pkg/controller/sparkapplication/job.go
+++ b/pkg/controller/sparkapplication/job.go
@@ -130,6 +130,10 @@ func (sjm *realSubmissionJobManager) createSubmissionJob(app *v1beta2.SparkAppli
 	if app.Spec.ServiceAccount != nil {
 		job.Spec.Template.Spec.ServiceAccountName = *app.Spec.ServiceAccount
 	}
+
+	if len(app.Spec.NodeSelector) > 0 {
+		job.Spec.Template.Spec.NodeSelector = app.Spec.NodeSelector
+	}
 	// Copy the labels on the SparkApplication to the Job.
 	for key, val := range app.Labels {
 		job.Labels[key] = val