Fix test breakage
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/3ca52309 Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/3ca52309 Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/3ca52309 Branch: refs/heads/master Commit: 3ca52309f2af07e6dbca56017360a0a814b8f9ca Parents: 1592adf Author: Aaron Davidson <[email protected]> Authored: Sat Nov 2 00:29:31 2013 -0700 Committer: Aaron Davidson <[email protected]> Committed: Sun Nov 3 21:34:44 2013 -0800 ---------------------------------------------------------------------- .../scala/org/apache/spark/storage/DiskBlockManagerSuite.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/3ca52309/core/src/test/scala/org/apache/spark/storage/DiskBlockManagerSuite.scala ---------------------------------------------------------------------- diff --git a/core/src/test/scala/org/apache/spark/storage/DiskBlockManagerSuite.scala b/core/src/test/scala/org/apache/spark/storage/DiskBlockManagerSuite.scala index 12ca920..89a7c6e 100644 --- a/core/src/test/scala/org/apache/spark/storage/DiskBlockManagerSuite.scala +++ b/core/src/test/scala/org/apache/spark/storage/DiskBlockManagerSuite.scala @@ -14,7 +14,7 @@ class DiskBlockManagerSuite extends FunSuite with BeforeAndAfterEach { val shuffleBlockManager = new ShuffleBlockManager(null) { var idToSegmentMap = mutable.Map[ShuffleBlockId, FileSegment]() - override def getBlockLocation(id: ShuffleBlockId) = idToSegmentMap.get(id) + override def getBlockLocation(id: ShuffleBlockId) = idToSegmentMap(id) } var diskBlockManager: DiskBlockManager = _
