diff options
author | Reynold Xin <rxin@cs.berkeley.edu> | 2013-05-30 16:28:08 -0700 |
---|---|---|
committer | Reynold Xin <rxin@cs.berkeley.edu> | 2013-05-30 16:28:08 -0700 |
commit | f6ad3781b1d9a044789f114d13787b9d05223da3 (patch) | |
tree | 2ed333987a914776a14ab7a72726e6b77c44f91b /core/src/test/scala | |
parent | bed1b08169df91e97cb9ebaf8e58daeb655ff55d (diff) | |
download | spark-f6ad3781b1d9a044789f114d13787b9d05223da3.tar.gz spark-f6ad3781b1d9a044789f114d13787b9d05223da3.tar.bz2 spark-f6ad3781b1d9a044789f114d13787b9d05223da3.zip |
Fixed the flaky unpersist test in RDDSuite.
Diffstat (limited to 'core/src/test/scala')
-rw-r--r-- | core/src/test/scala/spark/RDDSuite.scala | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/core/src/test/scala/spark/RDDSuite.scala b/core/src/test/scala/spark/RDDSuite.scala index a761dd77c5..3f69e99780 100644 --- a/core/src/test/scala/spark/RDDSuite.scala +++ b/core/src/test/scala/spark/RDDSuite.scala @@ -106,9 +106,9 @@ class RDDSuite extends FunSuite with LocalSparkContext { sc = new SparkContext("local", "test") val rdd = sc.makeRDD(Array(1, 2, 3, 4), 2).cache() rdd.count - assert(sc.persistentRdds.isEmpty == false) + assert(sc.persistentRdds.isEmpty === false) rdd.unpersist() - assert(sc.persistentRdds.isEmpty == true) + assert(sc.persistentRdds.isEmpty === true) failAfter(Span(3000, Millis)) { try { @@ -116,12 +116,12 @@ class RDDSuite extends FunSuite with LocalSparkContext { Thread.sleep(200) } } catch { - case e: Exception => + case _ => { Thread.sleep(10) } // Do nothing. We might see exceptions because block manager // is racing this thread to remove entries from the driver. } } - assert(sc.getRDDStorageInfo.isEmpty == true) + assert(sc.getRDDStorageInfo.isEmpty === true) } test("caching with failures") { |