diff options
| author | Xiangrui Meng <meng@databricks.com> | 2015-09-24 08:25:44 -0700 |
|---|---|---|
| committer | Xiangrui Meng <meng@databricks.com> | 2015-09-24 08:25:44 -0700 |
| commit | 02144d6745ec0a6d8877d969feb82139bd22437f (patch) | |
| tree | 78c8b59523a2c8d51a9bfcfc1b337d80c647a2f8 /yarn | |
| parent | d91967e159f416924bbd7f0db25156588d4bd7b1 (diff) | |
| download | spark-02144d6745ec0a6d8877d969feb82139bd22437f.tar.gz spark-02144d6745ec0a6d8877d969feb82139bd22437f.tar.bz2 spark-02144d6745ec0a6d8877d969feb82139bd22437f.zip | |
Revert "[SPARK-6028][Core]A new RPC implemetation based on the network module"
This reverts commit 084e4e126211d74a79e8dbd2d0e604dd3c650822.
Diffstat (limited to 'yarn')
| -rw-r--r-- | yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala b/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala index 32d218169a..93621b44c9 100644 --- a/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala +++ b/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala @@ -556,7 +556,10 @@ private[spark] class ApplicationMaster( override val rpcEnv: RpcEnv, driver: RpcEndpointRef, isClusterMode: Boolean) extends RpcEndpoint with Logging { - driver.send(RegisterClusterManager(self)) + override def onStart(): Unit = { + driver.send(RegisterClusterManager(self)) + + } override def receive: PartialFunction[Any, Unit] = { case x: AddWebUIFilter => |