diff options
| -rw-r--r-- | core/src/main/scala/spark/executor/Executor.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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()) } |