diff options
author | Patrick Wendell <pwendell@gmail.com> | 2013-12-29 11:31:10 -0800 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2013-12-29 11:31:10 -0800 |
commit | faefea3fd8e24da059f1e35f618310aeabe2d847 (patch) | |
tree | 44304889cc072b1a4dfafc5c5fe0ff515dd07ccf | |
parent | 6ffa9bb226ac9ceec4a34f0011c35d2d9710f8f8 (diff) | |
download | spark-faefea3fd8e24da059f1e35f618310aeabe2d847.tar.gz spark-faefea3fd8e24da059f1e35f618310aeabe2d847.tar.bz2 spark-faefea3fd8e24da059f1e35f618310aeabe2d847.zip |
Adding driver ID to submission response
-rw-r--r-- | core/src/main/scala/org/apache/spark/deploy/client/DriverClient.scala | 2 | ||||
-rw-r--r-- | core/src/main/scala/org/apache/spark/deploy/master/Master.scala | 2 |
2 files changed, 2 insertions, 2 deletions
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 6257303830..a5f57637fb 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)) 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 efb9bf49f4..b8655c78db 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}") } } |