From d92b067350c44b9e47c8a5a12d89458be71f2e2b Mon Sep 17 00:00:00 2001
From: Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)>
Date: Tue, 21 Dec 2010 13:12:15 -0800
Subject: [PATCH] Fixed log message in CustomParallelLocalFileShuffle that was
giving some problem in log processing.
---
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 aa08d1a195..a98b14fa5e 100644
--- a/src/scala/spark/CustomParallelLocalFileShuffle.scala
+++ b/src/scala/spark/CustomParallelLocalFileShuffle.scala
@@ -155,9 +155,6 @@ extends Shuffle[K, V, C] with Logging {
private var receptionSucceeded = false
override def run: Unit = {
- val readStartTime = System.currentTimeMillis
- logInfo("BEGIN READ: http://%s:%d/shuffle/%s".format(hostAddress, listenPort, requestPath))
-
// Setup the timeout mechanism
var timeOutTask = new TimerTask {
override def run: Unit = {
@@ -190,6 +187,9 @@ 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) {
// Add this to combiners
--
GitLab