diff options
| author | Imran Rashid <imran@quantifind.com> | 2013-01-19 13:26:15 -0800 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-01-21 11:21:33 -0800 |
| commit | 5bf73df7f08b17719711a5f05f0b3390b4951272 (patch) | |
| tree | cdb5d995e69421a8c040f1c820b2409785c41ccd /core | |
| parent | aae5a920a4db0c31918a65a03ce7d2087826fd65 (diff) | |
| download | spark-5bf73df7f08b17719711a5f05f0b3390b4951272.tar.gz spark-5bf73df7f08b17719711a5f05f0b3390b4951272.tar.bz2 spark-5bf73df7f08b17719711a5f05f0b3390b4951272.zip | |
oops, fix stupid compile error
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala | 3 |
1 files changed, 2 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 08b9d6ff47..94886d3941 100644 --- a/core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala +++ b/core/src/main/scala/spark/scheduler/cluster/SparkDeploySchedulerBackend.scala @@ -40,7 +40,8 @@ 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.getSparkHome())) + val sparkHome = sc.getSparkHome().getOrElse(throw new IllegalArgumentException("must supply spark home for spark standalone")) + val jobDesc = new JobDescription(jobName, maxCores, executorMemory, command, new File(sparkHome)) client = new Client(sc.env.actorSystem, master, jobDesc, this) client.start() |