Skip to content
Snippets Groups Projects
Commit 016ce1fa authored by Patrick Wendell's avatar Patrick Wendell
Browse files

Using full package name for util

parent 540be6b1
No related branches found
No related tags found
No related merge requests found
......@@ -5,7 +5,7 @@ import scala.collection.mutable.ArrayBuffer
import scala.collection.mutable.HashMap
import spark.storage.BlockManagerId
import util.CompletionIterator
import spark.util.CompletionIterator
private[spark] class BlockStoreShuffleFetcher extends ShuffleFetcher with Logging {
override def fetch[K, V](shuffleId: Int, reduceId: Int, metrics: TaskMetrics) = {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment