diff --git a/core/src/test/scala/org/apache/spark/CacheManagerSuite.scala b/core/src/test/scala/org/apache/spark/CacheManagerSuite.scala index 214f8244d5091471802476a4d3ceb7ff10fd7848..3a7171c48822155be972d57ae8c1c9d0b3e2e7eb 100644 --- a/core/src/test/scala/org/apache/spark/CacheManagerSuite.scala +++ b/core/src/test/scala/org/apache/spark/CacheManagerSuite.scala @@ -39,7 +39,7 @@ class CacheManagerSuite extends FunSuite with BeforeAndAfter with EasyMockSugar blockManager = mock[BlockManager] cacheManager = new CacheManager(blockManager) split = new Partition { override def index: Int = 0 } - rdd = new RDD(sc, Nil) { + rdd = new RDD[Int](sc, Nil) { override def getPartitions: Array[Partition] = Array(split) override val getDependencies = List[Dependency[_]]() override def compute(split: Partition, context: TaskContext) = Array(1, 2, 3, 4).iterator