-
- Downloads
[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
Showing
- core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/rpc/RpcEnv.scala
- streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisorImpl.scala 16 additions, 36 deletions...che/spark/streaming/receiver/ReceiverSupervisorImpl.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverInfo.scala 2 additions, 2 deletions...a/org/apache/spark/streaming/scheduler/ReceiverInfo.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala 33 additions, 31 deletions...rg/apache/spark/streaming/scheduler/ReceiverTracker.scala
Loading
Please register or sign in to comment