diff options
| author | Xiangrui Meng <meng@databricks.com> | 2015-09-24 08:25:44 -0700 |
|---|---|---|
| committer | Xiangrui Meng <meng@databricks.com> | 2015-09-24 08:25:44 -0700 |
| commit | 02144d6745ec0a6d8877d969feb82139bd22437f (patch) | |
| tree | 78c8b59523a2c8d51a9bfcfc1b337d80c647a2f8 /streaming | |
| parent | d91967e159f416924bbd7f0db25156588d4bd7b1 (diff) | |
| download | spark-02144d6745ec0a6d8877d969feb82139bd22437f.tar.gz spark-02144d6745ec0a6d8877d969feb82139bd22437f.tar.bz2 spark-02144d6745ec0a6d8877d969feb82139bd22437f.zip | |
Revert "[SPARK-6028][Core]A new RPC implemetation based on the network module"
This reverts commit 084e4e126211d74a79e8dbd2d0e604dd3c650822.
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 d053e9e849..204e6142fd 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.senderAddress) + registerReceiver(streamId, typ, hostPort, receiverEndpoint, context.sender.address) context.reply(successful) case AddBlock(receivedBlockInfo) => context.reply(addBlock(receivedBlockInfo)) |