Someone forgot to pass the parameters: fixes SPARK_MEM set from main script but not passed to executor.

2010-12-11 23:42:45 -08:00 · 2010-12-11 23:42:45 -08:00 · 34395730db
parent 0d895ba636
commit 34395730db
1 changed files with 1 additions and 1 deletions
--- a/src/scala/spark/MesosScheduler.scala
+++ b/src/scala/spark/MesosScheduler.scala
@ -98,7 +98,7 @@ extends MScheduler with spark.Scheduler with Logging
        params("env." + key) = System.getenv(key)
      }
    }
-    new ExecutorInfo(execScript, createExecArg())
+    new ExecutorInfo(execScript, createExecArg(), params)
  }

  /**