From 47b38fd207c703c4bb7e7b771f399c15292ab944 Mon Sep 17 00:00:00 2001
From: Matei Zaharia <matei@eecs.berkeley.edu>
Date: Sat, 16 Oct 2010 09:21:43 -0700
Subject: [PATCH] Bug fix in passing env vars to executors
---
src/scala/spark/MesosScheduler.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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)
}
--
GitLab