Skip to content

Commit

Permalink
shuffle fetch fail output
Browse files Browse the repository at this point in the history
  • Loading branch information
adrian-wang committed Sep 26, 2014
1 parent 74fb2ec commit 6c1b1e0
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -121,7 +121,7 @@ final class ShuffleBlockFetcherIterator(
}

override def onBlockFetchFailure(e: Throwable): Unit = {
logError("Failed to get block(s) from ${req.address.host}:${req.address.port}", e)
logError(s"Failed to get block(s) from ${req.address.host}:${req.address.port}", e)
// Note that there is a chance that some blocks have been fetched successfully, but we
// still add them to the failed queue. This is fine because when the caller see a
// FetchFailedException, it is going to fail the entire task anyway.
Expand Down

0 comments on commit 6c1b1e0

Please sign in to comment.