diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-10-03 01:04:35 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-10-03 01:04:35 -0700 |
| commit | 107320c9bbfe2496963a4e75e60fd6ba7fbfbabc (patch) | |
| tree | 869ad3f1a13445c563493492075feb77d4c45606 /yarn | |
| parent | 314bc68435ac3901a97724b9eccd1daf8f89578e (diff) | |
| download | spark-107320c9bbfe2496963a4e75e60fd6ba7fbfbabc.tar.gz spark-107320c9bbfe2496963a4e75e60fd6ba7fbfbabc.tar.bz2 spark-107320c9bbfe2496963a4e75e60fd6ba7fbfbabc.zip | |
[SPARK-6028] [CORE] Remerge #6457: new RPC implemetation and also pick #8905
This PR just reverted https://github.com/apache/spark/commit/02144d6745ec0a6d8877d969feb82139bd22437f to remerge #6457 and also included the commits in #8905.
Author: zsxwing <zsxwing@gmail.com>
Closes #8944 from zsxwing/SPARK-6028.
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 07a0a45e60..0df31736c1 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 => |