diff options
| author | Shivaram Venkataraman <shivaram@eecs.berkeley.edu> | 2012-08-03 18:45:18 -0700 |
|---|---|---|
| committer | Shivaram Venkataraman <shivaram@eecs.berkeley.edu> | 2012-08-03 18:52:26 -0700 |
| commit | ce3444d2cb189589ca01e065e4b6ee4bba7b11e3 (patch) | |
| tree | 86a947989f9662dde73b90697f7d09a34a120480 /core/src/test/scala | |
| parent | 62898b631fe6584ff93e62948765f7101304ebfa (diff) | |
| download | spark-ce3444d2cb189589ca01e065e4b6ee4bba7b11e3.tar.gz spark-ce3444d2cb189589ca01e065e4b6ee4bba7b11e3.tar.bz2 spark-ce3444d2cb189589ca01e065e4b6ee4bba7b11e3.zip | |
Fix testcheckpoint to reuse spark context defined in the class
Diffstat (limited to 'core/src/test/scala')
| -rw-r--r-- | core/src/test/scala/spark/RDDSuite.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/core/src/test/scala/spark/RDDSuite.scala b/core/src/test/scala/spark/RDDSuite.scala index 20638bba92..c467a7f916 100644 --- a/core/src/test/scala/spark/RDDSuite.scala +++ b/core/src/test/scala/spark/RDDSuite.scala @@ -61,9 +61,8 @@ class RDDSuite extends FunSuite with BeforeAndAfter { } test("checkpointing") { - val sc = new SparkContext("local", "test") + sc = new SparkContext("local", "test") val rdd = sc.makeRDD(Array(1, 2, 3, 4), 2).flatMap(x => 1 to x).checkpoint() assert(rdd.collect().toList === List(1, 1, 2, 1, 2, 3, 1, 2, 3, 4)) - sc.stop() } } |