diff options
| author | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-18 09:58:46 -0800 |
|---|---|---|
| committer | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-11-18 09:58:46 -0800 |
| commit | dfa6540fdda10b97c3dee4dddc0d0619ae0948fd (patch) | |
| tree | 581c876887f8f40fcfd782e83f231af2904f6a0e | |
| parent | b58bbadbfbaaaa5f3de79e65e5a5e1928ae39d68 (diff) | |
| download | spark-dfa6540fdda10b97c3dee4dddc0d0619ae0948fd.tar.gz spark-dfa6540fdda10b97c3dee4dddc0d0619ae0948fd.tar.bz2 spark-dfa6540fdda10b97c3dee4dddc0d0619ae0948fd.zip | |
Everyone logs 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 2750aef289..dd03ac839e 100644 --- a/src/scala/spark/Broadcast.scala +++ b/src/scala/spark/Broadcast.scala @@ -75,6 +75,8 @@ extends BroadcastRecipe with Logging { } def sendBroadcast () { + logInfo ("Local host address: " + hostAddress) + // Store a persistent copy in HDFS // TODO: Turned OFF for now // val out = new ObjectOutputStream (BroadcastCH.openFileForWriting(uuid)) |