Minor mods

2012-12-02 02:39:08 +00:00 · 2012-12-02 02:39:08 +00:00 · 609e00d599
parent b4dba55f78
commit 609e00d599
1 changed files with 1 additions and 1 deletions
--- 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) => {