You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/09/26 20:26:59 UTC
git commit: [SPARK-3695]shuffle fetch fail output
Repository: spark
Updated Branches:
refs/heads/master ec9df6a76 -> 30461c6ac
[SPARK-3695]shuffle fetch fail output
should output detailed host and port in error message
Author: Daoyuan Wang <da...@intel.com>
Closes #2539 from adrian-wang/fetchfail and squashes the following commits:
6c1b1e0 [Daoyuan Wang] shuffle fetch fail output
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/30461c6a
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/30461c6a
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/30461c6a
Branch: refs/heads/master
Commit: 30461c6ac3dcfb05dc1891494ec161601c0fb59f
Parents: ec9df6a
Author: Daoyuan Wang <da...@intel.com>
Authored: Fri Sep 26 11:26:53 2014 -0700
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Fri Sep 26 11:26:53 2014 -0700
----------------------------------------------------------------------
.../org/apache/spark/storage/ShuffleBlockFetcherIterator.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/30461c6a/core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala b/core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
index d868758..71b276b 100644
--- a/core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
+++ b/core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala
@@ -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.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org