diff options
| author | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-18 09:55:19 -0800 |
|---|---|---|
| committer | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-18 09:55:19 -0800 |
| commit | 1f2662d45a465edd6f4597d9916a05642209e261 (patch) | |
| tree | 1ee0ed7ae48642fec339f48c510fe6f8fd1d8bb0 | |
| parent | c3f354c6fc99424c0b405e65266ee0a8c82dd07d (diff) | |
| download | spark-1f2662d45a465edd6f4597d9916a05642209e261.tar.gz spark-1f2662d45a465edd6f4597d9916a05642209e261.tar.bz2 spark-1f2662d45a465edd6f4597d9916a05642209e261.zip | |
Everyone logs their local hostAddress.
| -rw-r--r-- | src/scala/spark/Broadcast.scala | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/scala/spark/Broadcast.scala b/src/scala/spark/Broadcast.scala index 1b3c4e9c48..a203b04895 100644 --- a/src/scala/spark/Broadcast.scala +++ b/src/scala/spark/Broadcast.scala @@ -73,6 +73,8 @@ extends BroadcastRecipe with Logging { } def sendBroadcast (): Unit = { + logInfo ("Local host address: " + hostAddress) + // Store a persistent copy in HDFS // TODO: Turned OFF for now // val out = new ObjectOutputStream (BroadcastCH.openFileForWriting(uuid)) |