diff --git a/core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala b/core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala index 57655aa4c32b1..04f686b2c24e6 100644 --- a/core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala +++ b/core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala @@ -105,6 +105,8 @@ private[spark] class SparkSubmitArguments(args: Seq[String]) { .getOrElse(defaultProperties.get("spark.cores.max").orNull) name = Option(name).getOrElse(defaultProperties.get("spark.app.name").orNull) jars = Option(jars).getOrElse(defaultProperties.get("spark.jars").orNull) + numExecutors = Option(numExecutors) + .getOrElse(defaultProperties.get("spark.executor.instances").orNull) // This supports env vars in older versions of Spark master = Option(master).getOrElse(System.getenv("MASTER"))