diff options
| author | Imran Rashid <imran@quantifind.com> | 2013-01-18 13:28:50 -0800 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-01-21 11:21:28 -0800 |
| commit | aae5a920a4db0c31918a65a03ce7d2087826fd65 (patch) | |
| tree | 7aeaf0d9c1e6fe2a55796348c4182ca06066e199 /core | |
| parent | f116d6b5c6029c2f96160bd84829a6fe8b73cccf (diff) | |
| download | spark-aae5a920a4db0c31918a65a03ce7d2087826fd65.tar.gz spark-aae5a920a4db0c31918a65a03ce7d2087826fd65.tar.bz2 spark-aae5a920a4db0c31918a65a03ce7d2087826fd65.zip | |
get sparkHome the correct way
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala b/core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala index 0dcc2efaca..08b9d6ff47 100644 --- a/core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala +++ b/core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala @@ -40,7 +40,7 @@ private[spark] class SparkDeploySchedulerBackend( StandaloneSchedulerBackend.ACTOR_NAME) val args = Seq(masterUrl, "{{SLAVEID}}", "{{HOSTNAME}}", "{{CORES}}") val command = Command("spark.executor.StandaloneExecutorBackend", args, sc.executorEnvs) - val jobDesc = new JobDescription(jobName, maxCores, executorMemory, command, new File(sc.sparkHome)) + val jobDesc = new JobDescription(jobName, maxCores, executorMemory, command, new File(sc.getSparkHome())) client = new Client(sc.env.actorSystem, master, jobDesc, this) client.start() |