diff --git a/src/scala/spark/MesosScheduler.scala b/src/scala/spark/MesosScheduler.scala
index bc24bf37fd1614ab33b6952b41ac91105c6205d5..080171ab785960defbb68ad0e07ef336316b202c 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)
   }