From 6ef17e918b482c9a6009d44a6079ad407b594e0d Mon Sep 17 00:00:00 2001
From: Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)>
Date: Tue, 21 Dec 2010 18:49:35 -0800
Subject: [PATCH] Fixed logging. Again.
---
src/scala/spark/CustomParallelLocalFileShuffle.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/src/scala/spark/CustomParallelLocalFileShuffle.scala b/src/scala/spark/CustomParallelLocalFileShuffle.scala
index 1b5e4ef929..9ec2a2dc66 100644
--- a/src/scala/spark/CustomParallelLocalFileShuffle.scala
+++ b/src/scala/spark/CustomParallelLocalFileShuffle.scala
@@ -187,11 +187,11 @@ extends Shuffle[K, V, C] with Logging {
// Turn the timer OFF, if the sender responds before timeout
timeOutTimer.cancel()
- val readStartTime = System.currentTimeMillis
- logInfo("BEGIN READ: http://%s:%d/shuffle/%s".format(hostAddress, listenPort, requestPath))
-
// Receive the file
if (requestedFileLen != -1) {
+ val readStartTime = System.currentTimeMillis
+ logInfo("BEGIN READ: http://%s:%d/shuffle/%s".format(hostAddress, listenPort, requestPath))
+
// Add this to combiners
val inputStream = new ObjectInputStream(isSource)
--
GitLab