From c6df327dd700c955d54b1b92f30e07bfeae08874 Mon Sep 17 00:00:00 2001
From: Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)>
Date: Sat, 4 Dec 2010 16:41:13 -0800
Subject: [PATCH] Updated logging format.
---
src/scala/spark/LocalFileShuffle.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/src/scala/spark/LocalFileShuffle.scala b/src/scala/spark/LocalFileShuffle.scala
index 9a5b0ff7d5..a26bb08dbb 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)
}
--
GitLab