diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-09-23 18:59:49 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-09-23 18:59:49 -0700 |
| commit | 084e4e126211d74a79e8dbd2d0e604dd3c650822 (patch) | |
| tree | 4e4d3cfa381f15060d2a24404adf652742797933 /yarn | |
| parent | 9952217749118ae78fe794ca11e1c4a87a4ae8ba (diff) | |
| download | spark-084e4e126211d74a79e8dbd2d0e604dd3c650822.tar.gz spark-084e4e126211d74a79e8dbd2d0e604dd3c650822.tar.bz2 spark-084e4e126211d74a79e8dbd2d0e604dd3c650822.zip | |
[SPARK-6028][Core]A new RPC implemetation based on the network module
Design doc: https://docs.google.com/document/d/1CF5G6rGVQMKSyV_QKo4D2M-x6rxz5x1Ew7aK3Uq6u8c/edit?usp=sharing
Author: zsxwing <zsxwing@gmail.com>
Closes #6457 from zsxwing/new-rpc.
Diffstat (limited to 'yarn')
| -rw-r--r-- | yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala | 5 |
1 files changed, 1 insertions, 4 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 93621b44c9..32d218169a 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,10 +556,7 @@ private[spark] class ApplicationMaster( override val rpcEnv: RpcEnv, driver: RpcEndpointRef, isClusterMode: Boolean) extends RpcEndpoint with Logging { - override def onStart(): Unit = { - driver.send(RegisterClusterManager(self)) - - } + driver.send(RegisterClusterManager(self)) override def receive: PartialFunction[Any, Unit] = { case x: AddWebUIFilter => |