diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-04-19 20:35:43 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-04-19 20:35:43 -0700 |
| commit | d8e1b7b06c499289ff3ce5ec91ff354493a17c48 (patch) | |
| tree | b96a02111b44e147767e28f233ee323fa786ae87 /core | |
| parent | fa73da024000386eecef79573e8ac96d6f05b2c7 (diff) | |
| download | spark-d8e1b7b06c499289ff3ce5ec91ff354493a17c48.tar.gz spark-d8e1b7b06c499289ff3ce5ec91ff354493a17c48.tar.bz2 spark-d8e1b7b06c499289ff3ce5ec91ff354493a17c48.zip | |
[SPARK-6983][Streaming] Update ReceiverTrackerActor to use the new Rpc interface
A subtask of [SPARK-5293](https://issues.apache.org/jira/browse/SPARK-5293)
Author: zsxwing <zsxwing@gmail.com>
Closes #5557 from zsxwing/SPARK-6983 and squashes the following commits:
e777e9f [zsxwing] Update ReceiverTrackerActor to use the new Rpc interface
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala b/core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala index f2c1c86af7..cba038ca35 100644 --- a/core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala +++ b/core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala @@ -258,7 +258,7 @@ private[spark] trait RpcEndpoint { final def stop(): Unit = { val _self = self if (_self != null) { - rpcEnv.stop(self) + rpcEnv.stop(_self) } } } |