aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorTathagata Das <tathagata.das1565@gmail.com>2013-01-01 16:38:04 -0800
committerTathagata Das <tathagata.das1565@gmail.com>2013-01-01 16:38:04 -0800
commit3dc87dd923578f20f2c6945be7d8c03797e76237 (patch)
tree9969bb631125c0038a7b7943226623b74e7a7bc0
parentd34dba25c21736d6de3059f274636aa9cc47d868 (diff)
downloadspark-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.scala6
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")