From 2860c8a6a2b2a2110a16a22bb94cec6b23ae390a Mon Sep 17 00:00:00 2001 From: KaiXinXiaoLei Date: Sat, 5 Dec 2015 17:41:58 +0800 Subject: [PATCH] change code --- .../scala/org/apache/spark/deploy/SparkSubmitArguments.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 18a1c52ae53fb..2491e39ac094a 100644 --- a/core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala +++ b/core/src/main/scala/org/apache/spark/deploy/SparkSubmitArguments.scala @@ -177,7 +177,7 @@ private[deploy] class SparkSubmitArguments(args: Seq[String], env: Map[String, S packagesExclusions = Option(packagesExclusions) .orElse(sparkProperties.get("spark.jars.excludes")).orNull deployMode = Option(deployMode).orElse(env.get("DEPLOY_MODE")).orNull - numExecutors = Option(numExecutors) + numExecutors = Option(numExecutors).orElse(env.get("SPARK_EXECUTOR_INSTANCES")) .getOrElse(sparkProperties.get("spark.executor.instances").orNull) keytab = Option(keytab).orElse(sparkProperties.get("spark.yarn.keytab")).orNull principal = Option(principal).orElse(sparkProperties.get("spark.yarn.principal")).orNull