diff options
| author | Denny <dennybritz@gmail.com> | 2012-10-13 13:15:50 -0700 |
|---|---|---|
| committer | Denny <dennybritz@gmail.com> | 2012-10-13 13:15:50 -0700 |
| commit | fa41d50f7d666bee015c06d7d4113f6ccac20c30 (patch) | |
| tree | 2c6193d0920f03786d5f95d62487adda46aa1cfc /core/src/main | |
| parent | 67c42a41d09b6f134d1d8d5387dd331fea49a737 (diff) | |
| download | spark-fa41d50f7d666bee015c06d7d4113f6ccac20c30.tar.gz spark-fa41d50f7d666bee015c06d7d4113f6ccac20c30.tar.bz2 spark-fa41d50f7d666bee015c06d7d4113f6ccac20c30.zip | |
Don't use system envs for Mesos.
Diffstat (limited to 'core/src/main')
| -rw-r--r-- | core/src/main/scala/spark/scheduler/mesos/CoarseMesosSchedulerBackend.scala | 2 | ||||
| -rw-r--r-- | core/src/main/scala/spark/scheduler/mesos/MesosSchedulerBackend.scala | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/scheduler/mesos/CoarseMesosSchedulerBackend.scala b/core/src/main/scala/spark/scheduler/mesos/CoarseMesosSchedulerBackend.scala index 37746827a8..cb378e62fc 100644 --- a/core/src/main/scala/spark/scheduler/mesos/CoarseMesosSchedulerBackend.scala +++ b/core/src/main/scala/spark/scheduler/mesos/CoarseMesosSchedulerBackend.scala @@ -117,7 +117,7 @@ private[spark] class CoarseMesosSchedulerBackend( sc.executorEnvs.foreach { case(k,v) => environment.addVariables(Environment.Variable.newBuilder() .setName(k) - .setValue(System.getenv(v)) + .setValue(v) .build()) } return CommandInfo.newBuilder().setValue(command).setEnvironment(environment).build() diff --git a/core/src/main/scala/spark/scheduler/mesos/MesosSchedulerBackend.scala b/core/src/main/scala/spark/scheduler/mesos/MesosSchedulerBackend.scala index f3bee8e1e7..055ad7b728 100644 --- a/core/src/main/scala/spark/scheduler/mesos/MesosSchedulerBackend.scala +++ b/core/src/main/scala/spark/scheduler/mesos/MesosSchedulerBackend.scala @@ -88,7 +88,7 @@ private[spark] class MesosSchedulerBackend( sc.executorEnvs.foreach { case(k,v) => environment.addVariables(Environment.Variable.newBuilder() .setName(k) - .setValue(System.getenv(v)) + .setValue(v) .build()) } val memory = Resource.newBuilder() |