diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-01-01 16:38:04 -0800 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-01-01 16:38:04 -0800 |
commit | 3dc87dd923578f20f2c6945be7d8c03797e76237 (patch) | |
tree | 9969bb631125c0038a7b7943226623b74e7a7bc0 | |
parent | d34dba25c21736d6de3059f274636aa9cc47d868 (diff) | |
download | spark-3dc87dd923578f20f2c6945be7d8c03797e76237.tar.gz spark-3dc87dd923578f20f2c6945be7d8c03797e76237.tar.bz2 spark-3dc87dd923578f20f2c6945be7d8c03797e76237.zip |
Fixed compilation bug in RDDSuite created during merge for mesos/master.
-rw-r--r-- | core/src/test/scala/spark/RDDSuite.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/core/src/test/scala/spark/RDDSuite.scala b/core/src/test/scala/spark/RDDSuite.scala index eab09956bb..e5a59dc7d6 100644 --- a/core/src/test/scala/spark/RDDSuite.scala +++ b/core/src/test/scala/spark/RDDSuite.scala @@ -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") |