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 /streaming | |
| 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 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala index 204e6142fd..d053e9e849 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala @@ -474,7 +474,7 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false // Remote messages case RegisterReceiver(streamId, typ, hostPort, receiverEndpoint) => val successful = - registerReceiver(streamId, typ, hostPort, receiverEndpoint, context.sender.address) + registerReceiver(streamId, typ, hostPort, receiverEndpoint, context.senderAddress) context.reply(successful) case AddBlock(receivedBlockInfo) => context.reply(addBlock(receivedBlockInfo)) |