diff options
author | Reynold Xin <rxin@cs.berkeley.edu> | 2013-05-04 21:49:50 -0700 |
---|---|---|
committer | Reynold Xin <rxin@cs.berkeley.edu> | 2013-05-04 21:49:50 -0700 |
commit | 62a077cd08fbb676f67f75a579c31aa401635c88 (patch) | |
tree | 689c1a3c6bb4995ec155689ab43a8287727760bf /core | |
parent | 3bf2c868c311f6afd286d7a25adda9fe94561eb0 (diff) | |
parent | 2274ad0786b758e3170e96815e9693ea27635f06 (diff) | |
download | spark-62a077cd08fbb676f67f75a579c31aa401635c88.tar.gz spark-62a077cd08fbb676f67f75a579c31aa401635c88.tar.bz2 spark-62a077cd08fbb676f67f75a579c31aa401635c88.zip |
Merge branch 'unpersist-test' of github.com:shivaram/spark into blockmanager
Diffstat (limited to 'core')
-rw-r--r-- | core/src/test/scala/spark/DistributedSuite.scala | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/core/src/test/scala/spark/DistributedSuite.scala b/core/src/test/scala/spark/DistributedSuite.scala index ab3e197035..a13c88cfb4 100644 --- a/core/src/test/scala/spark/DistributedSuite.scala +++ b/core/src/test/scala/spark/DistributedSuite.scala @@ -261,9 +261,9 @@ class DistributedSuite extends FunSuite with ShouldMatchers with BeforeAndAfter val data = sc.parallelize(Seq(true, false, false, false), 4) data.persist(StorageLevel.MEMORY_ONLY_2) data.count - assert(sc.persistentRdds.isEmpty == false) + assert(sc.persistentRdds.isEmpty === false) data.unpersist() - assert(sc.persistentRdds.isEmpty == true) + assert(sc.persistentRdds.isEmpty === true) failAfter(Span(3000, Millis)) { try { @@ -271,12 +271,12 @@ class DistributedSuite extends FunSuite with ShouldMatchers with BeforeAndAfter 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) } } |