aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorKay Ousterhout <kayousterhout@gmail.com>2013-10-06 18:45:43 -0700
committerKay Ousterhout <kayousterhout@gmail.com>2013-10-06 18:45:43 -0700
commitfdc52b2f8b2fda38252bc1b6d56c74b21ec234d4 (patch)
tree62dc5a2e3ed209759779518c42ff7d3c681ea8fd
parent7b5ae23a376f63f70eb4a368e76cfd5c7653309d (diff)
downloadspark-fdc52b2f8b2fda38252bc1b6d56c74b21ec234d4.tar.gz
spark-fdc52b2f8b2fda38252bc1b6d56c74b21ec234d4.tar.bz2
spark-fdc52b2f8b2fda38252bc1b6d56c74b21ec234d4.zip
Added back fully qualified class name
-rw-r--r--core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackend.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackend.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackend.scala
index 4b131d87ce..300fe693f1 100644
--- a/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackend.scala
+++ b/core/src/main/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackend.scala
@@ -128,7 +128,7 @@ private[spark] class CoarseMesosSchedulerBackend(
if (uri == null) {
val runScript = new File(sparkHome, "spark-class").getCanonicalPath
command.setValue(
- "\"%s\" CoarseGrainedExecutorBackend %s %s %s %d".format(
+ "\"%s\" org.apache.spark.executor.CoarseGrainedExecutorBackend %s %s %s %d".format(
runScript, driverUrl, offer.getSlaveId.getValue, offer.getHostname, numCores))
} else {
// Grab everything to the first '.'. We'll use that and '*' to