Bug fix in passing env vars to executors

This commit is contained in:
Matei Zaharia 2010-10-16 09:21:43 -07:00
parent 6c1dee2e42
commit 47b38fd207

View file

@ -95,7 +95,7 @@ extends MScheduler with spark.Scheduler with Logging
val params = new JHashMap[String, String]
for (key <- ENV_VARS_TO_SEND_TO_EXECUTORS) {
if (System.getenv(key) != null)
params(key) = System.getenv(key)
params("env." + key) = System.getenv(key)
}
new ExecutorInfo(execScript, execArg)
}