Change Executor to only look at the env variable SPARK_YARN_MODE

This commit is contained in:
Y.CORP.YAHOO.COM\tgraves 2013-08-28 13:26:26 -05:00
Родитель 3f206bf0b5
Коммит aac1214ee4
1 изменённых файлов: 1 добавлений и 1 удалений

Просмотреть файл

@ -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())
}