diff --git a/src/scala/spark/CustomParallelLocalFileShuffle.scala b/src/scala/spark/CustomParallelLocalFileShuffle.scala index 1b5e4ef9292dfcac2031fd8056e8774f752f2c44..9ec2a2dc66dded60895a8b52ad0bd378c23a7a89 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)