Skip to content
Snippets Groups Projects
Commit 3dc87dd9 authored by Tathagata Das's avatar Tathagata Das
Browse files

Fixed compilation bug in RDDSuite created during merge for mesos/master.

parent d34dba25
No related branches found
No related tags found
No related merge requests found
......@@ -105,9 +105,9 @@ class RDDSuite extends FunSuite with BeforeAndAfter {
sc = new SparkContext("local", "test")
val onlySplit = new Split { override def index: Int = 0 }
var shouldFail = true
val rdd = new RDD[Int](sc) {
override def splits: Array[Split] = Array(onlySplit)
override val dependencies = List[Dependency[_]]()
val rdd = new RDD[Int](sc, Nil) {
override def getSplits: Array[Split] = Array(onlySplit)
override val getDependencies = List[Dependency[_]]()
override def compute(split: Split, context: TaskContext): Iterator[Int] = {
if (shouldFail) {
throw new Exception("injected failure")
......
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