diff --git a/src/scala/spark/LocalFileShuffle.scala b/src/scala/spark/LocalFileShuffle.scala
index 9a5b0ff7d5a06b80e09f87e17c51eccbd3b0cbe8..a26bb08dbb2278f4eb22935f7e2f1080d3f4a07c 100644
--- a/src/scala/spark/LocalFileShuffle.scala
+++ b/src/scala/spark/LocalFileShuffle.scala
@@ -150,7 +150,7 @@ class LocalFileShuffle[K, V, C] extends Shuffle[K, V, C] with Logging {
 
     override def run: Unit = {
       val readStartTime = System.currentTimeMillis
-      logInfo ("BEGIN READ: " + requestPath)
+      logInfo ("BEGIN READ: http://%s:%d/shuffle/%s".format(hostAddress, listenPort, requestPath))
 
       // Setup the timeout mechanism
       var timeOutTask = new TimerTask {
@@ -216,9 +216,9 @@ class LocalFileShuffle[K, V, C] extends Shuffle[K, V, C] with Logging {
           
           receptionSucceeded = true
 
-          logInfo ("END READ: " + requestPath)
+          logInfo ("END READ: http://%s:%d/shuffle/%s".format(hostAddress, listenPort, requestPath))
           val readTime = (System.currentTimeMillis - readStartTime)
-          logInfo ("Reading " + requestPath + " took " + readTime + " millis.")
+          logInfo ("Reading http://%s:%d/shuffle/%s".format(hostAddress, listenPort, requestPath) + " took " + readTime + " millis.")
         } else {
           throw new SparkException("ShuffleServer " + hostAddress + " does not have " + requestPath)
         }