diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2010-10-16 09:21:43 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2010-10-16 09:21:43 -0700 |
| commit | 47b38fd207c703c4bb7e7b771f399c15292ab944 (patch) | |
| tree | ffb089bb59960349bb11b8528400f3be6f522b60 | |
| parent | 6c1dee2e42587e5722bdec86bd102c120e2e1dee (diff) | |
| download | spark-47b38fd207c703c4bb7e7b771f399c15292ab944.tar.gz spark-47b38fd207c703c4bb7e7b771f399c15292ab944.tar.bz2 spark-47b38fd207c703c4bb7e7b771f399c15292ab944.zip | |
Bug fix in passing env vars to executors
| -rw-r--r-- | src/scala/spark/MesosScheduler.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/scala/spark/MesosScheduler.scala b/src/scala/spark/MesosScheduler.scala index bc24bf37fd..080171ab78 100644 --- a/src/scala/spark/MesosScheduler.scala +++ b/src/scala/spark/MesosScheduler.scala @@ -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) } |