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 /streaming | |
| 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 '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)) |