Fixed logging. Again.

This commit is contained in:
Mosharaf Chowdhury 2010-12-21 18:49:35 -08:00
parent f47fb44479
commit 6ef17e918b

View file

@ -187,11 +187,11 @@ extends Shuffle[K, V, C] with Logging {
// Turn the timer OFF, if the sender responds before timeout
timeOutTimer.cancel()
// Receive the file
if (requestedFileLen != -1) {
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
val inputStream = new ObjectInputStream(isSource)