From b70c945220dacb81a1343f3b0ed4d2a13c8cc76e Mon Sep 17 00:00:00 2001 From: Matt Massie Date: Tue, 2 Jun 2015 15:09:37 -0700 Subject: [PATCH] Make BlockStoreShuffleFetcher visible to shuffle package --- .../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 9a15f9bab834a..e93d0ba950266 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 @@ -27,7 +27,7 @@ import org.apache.spark.shuffle.FetchFailedException import org.apache.spark.storage.{BlockId, BlockManagerId, ShuffleBlockFetcherIterator, ShuffleBlockId} import org.apache.spark.util.CompletionIterator -private[hash] object BlockStoreShuffleFetcher extends Logging { +private[shuffle] object BlockStoreShuffleFetcher extends Logging { def fetchBlockStreams( shuffleId: Int, reduceId: Int,