From aac1214ee48ef143b0164f740380cdb0a5a7383b Mon Sep 17 00:00:00 2001 From: "Y.CORP.YAHOO.COM\\tgraves" Date: Wed, 28 Aug 2013 13:26:26 -0500 Subject: [PATCH] Change Executor to only look at the env variable SPARK_YARN_MODE --- core/src/main/scala/spark/executor/Executor.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/spark/executor/Executor.scala b/core/src/main/scala/spark/executor/Executor.scala index 25f55b391b..fa82d2b324 100644 --- a/core/src/main/scala/spark/executor/Executor.scala +++ b/core/src/main/scala/spark/executor/Executor.scala @@ -63,7 +63,7 @@ private[spark] class Executor( // If we are in yarn mode, systems can have different disk layouts so we must set it // to what Yarn on this system said was available. This will be used later when SparkEnv // created. - if (java.lang.Boolean.valueOf(System.getProperty("SPARK_YARN_MODE", System.getenv("SPARK_YARN_MODE")))) { + if (java.lang.Boolean.valueOf(System.getenv("SPARK_YARN_MODE"))) { System.setProperty("spark.local.dir", getYarnLocalDirs()) }