Skip to content
Snippets Groups Projects
Commit 1e15feb5 authored by Reynold Xin's avatar Reynold Xin
Browse files

Hot fix to resolve the compilation error caused by SPARK-821.

parent ddcb9d31
No related branches found
No related tags found
No related merge requests found
...@@ -39,7 +39,7 @@ class CacheManagerSuite extends FunSuite with BeforeAndAfter with EasyMockSugar ...@@ -39,7 +39,7 @@ class CacheManagerSuite extends FunSuite with BeforeAndAfter with EasyMockSugar
blockManager = mock[BlockManager] blockManager = mock[BlockManager]
cacheManager = new CacheManager(blockManager) cacheManager = new CacheManager(blockManager)
split = new Partition { override def index: Int = 0 } 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 def getPartitions: Array[Partition] = Array(split)
override val getDependencies = List[Dependency[_]]() override val getDependencies = List[Dependency[_]]()
override def compute(split: Partition, context: TaskContext) = Array(1, 2, 3, 4).iterator override def compute(split: Partition, context: TaskContext) = Array(1, 2, 3, 4).iterator
......
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