diff options
| author | Daoyuan Wang <daoyuan.wang@intel.com> | 2014-09-26 11:26:53 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-09-26 11:26:53 -0700 |
| commit | 30461c6ac3dcfb05dc1891494ec161601c0fb59f (patch) | |
| tree | a25bb1fd6bf4e33ef6aa285b705da7774163032f /core | |
| parent | ec9df6a765701fa41390083df12e1dc1fee50662 (diff) | |
| download | spark-30461c6ac3dcfb05dc1891494ec161601c0fb59f.tar.gz spark-30461c6ac3dcfb05dc1891494ec161601c0fb59f.tar.bz2 spark-30461c6ac3dcfb05dc1891494ec161601c0fb59f.zip | |
[SPARK-3695]shuffle fetch fail output
should output detailed host and port in error message
Author: Daoyuan Wang <daoyuan.wang@intel.com>
Closes #2539 from adrian-wang/fetchfail and squashes the following commits:
6c1b1e0 [Daoyuan Wang] shuffle fetch fail output
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/storage/ShuffleBlockFetcherIterator.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 d868758a7f..71b276b5f1 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. |