You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/01/10 03:38:25 UTC
[20/37] git commit: Adding driver ID to submission response
Adding driver ID to submission response
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/faefea3f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/faefea3f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/faefea3f
Branch: refs/heads/master
Commit: faefea3fd8e24da059f1e35f618310aeabe2d847
Parents: 6ffa9bb
Author: Patrick Wendell <pw...@gmail.com>
Authored: Sun Dec 29 11:31:10 2013 -0800
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Sun Dec 29 11:31:10 2013 -0800
----------------------------------------------------------------------
.../main/scala/org/apache/spark/deploy/client/DriverClient.scala | 2 +-
core/src/main/scala/org/apache/spark/deploy/master/Master.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/faefea3f/core/src/main/scala/org/apache/spark/deploy/client/DriverClient.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/deploy/client/DriverClient.scala b/core/src/main/scala/org/apache/spark/deploy/client/DriverClient.scala
index 6257303..a5f5763 100644
--- a/core/src/main/scala/org/apache/spark/deploy/client/DriverClient.scala
+++ b/core/src/main/scala/org/apache/spark/deploy/client/DriverClient.scala
@@ -43,7 +43,7 @@ class DriverActor(master: String, response: Promise[(Boolean, String)]) extends
response.success((success, message))
}
- // Relay all other messages to the server.
+ // Relay all other messages to the master.
case message => {
logInfo(s"Sending message to master $master...")
val masterActor = context.actorSelection(Master.toAkkaUrl(master))
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/faefea3f/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/deploy/master/Master.scala b/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
index efb9bf4..b8655c7 100644
--- a/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
+++ b/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
@@ -189,7 +189,7 @@ private[spark] class Master(host: String, port: Int, webUiPort: Int) extends Act
// TODO: It might be good to instead have the submission client poll the master to determine
// the current status of the driver. For now it's simply "fire and forget".
- sender ! SubmitDriverResponse(true, "Driver successfully submitted")
+ sender ! SubmitDriverResponse(true, s"Driver successfully submitted as ${driver.id}")
}
}