From 4e946f7349db8468375f40fa526c6892f5145759 Mon Sep 17 00:00:00 2001 From: zsxwing Date: Sun, 2 Nov 2014 15:51:08 +0800 Subject: [PATCH] Add e as the cause of SparkException --- .../apache/spark/shuffle/hash/BlockStoreShuffleFetcher.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/shuffle/hash/BlockStoreShuffleFetcher.scala b/core/src/main/scala/org/apache/spark/shuffle/hash/BlockStoreShuffleFetcher.scala index 4638b3310ad8f..af98159d63460 100644 --- a/core/src/main/scala/org/apache/spark/shuffle/hash/BlockStoreShuffleFetcher.scala +++ b/core/src/main/scala/org/apache/spark/shuffle/hash/BlockStoreShuffleFetcher.scala @@ -67,7 +67,7 @@ private[hash] object BlockStoreShuffleFetcher extends Logging { throw new FetchFailedException(address, shufId.toInt, mapId.toInt, reduceId, e) case _ => throw new SparkException( - "Failed to get block " + blockId + ", which is not a shuffle block") + "Failed to get block " + blockId + ", which is not a shuffle block", e) } } }