diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2012-12-02 02:39:08 +0000 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2012-12-02 02:39:08 +0000 |
| commit | 609e00d599d3f429a838f598b3f32c5fdbd7ec5e (patch) | |
| tree | 640cf03e9d467442508c53186efcdcc724741ef4 /streaming/src | |
| parent | b4dba55f78b0dfda728cf69c9c17e4863010d28d (diff) | |
| download | spark-609e00d599d3f429a838f598b3f32c5fdbd7ec5e.tar.gz spark-609e00d599d3f429a838f598b3f32c5fdbd7ec5e.tar.bz2 spark-609e00d599d3f429a838f598b3f32c5fdbd7ec5e.zip | |
Minor mods
Diffstat (limited to 'streaming/src')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/NetworkInputTracker.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/spark/streaming/NetworkInputTracker.scala b/streaming/src/main/scala/spark/streaming/NetworkInputTracker.scala index d0fef70f7e..ae6692290e 100644 --- a/streaming/src/main/scala/spark/streaming/NetworkInputTracker.scala +++ b/streaming/src/main/scala/spark/streaming/NetworkInputTracker.scala @@ -58,7 +58,7 @@ class NetworkInputTracker( throw new Exception("Register received for unexpected id " + streamId) } receiverInfo += ((streamId, receiverActor)) - logInfo("Registered receiver for network stream " + streamId) + logInfo("Registered receiver for network stream " + streamId + " from " + sender.path.address) sender ! true } case AddBlocks(streamId, blockIds) => { |