aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorDmitriy Lyubimov <dlyubimov@apache.org>2013-07-30 16:10:55 -0700
committerDmitriy Lyubimov <dlyubimov@apache.org>2013-07-30 16:10:55 -0700
commit13a9d666457533bd0c3991c1d3bc30474e08e580 (patch)
treeb0728ae509c9f5cbee96ce81822bbdbacb48d3df /core
parent1bca91633eaff0c44d60682622f57eebca09c4ff (diff)
downloadspark-13a9d666457533bd0c3991c1d3bc30474e08e580.tar.gz
spark-13a9d666457533bd0c3991c1d3bc30474e08e580.tar.bz2
spark-13a9d666457533bd0c3991c1d3bc30474e08e580.zip
adding ===
Diffstat (limited to 'core')
-rw-r--r--core/src/test/scala/spark/KryoSerializerSuite.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/test/scala/spark/KryoSerializerSuite.scala b/core/src/test/scala/spark/KryoSerializerSuite.scala
index 5ae7a427cc..158bf63132 100644
--- a/core/src/test/scala/spark/KryoSerializerSuite.scala
+++ b/core/src/test/scala/spark/KryoSerializerSuite.scala
@@ -131,13 +131,13 @@ class KryoSerializerSuite extends FunSuite with SharedSparkContext {
test("kryo with collect") {
val control = 1 :: 2 :: Nil
val result = sc.parallelize(control, 2).map(new ClassWithoutNoArgConstructor(_)).collect().map(_.x)
- assert(control == result.toSeq)
+ assert(control === result.toSeq)
}
test("kryo with parallelize") {
val control = 1 :: 2 :: Nil
val result = sc.parallelize(control.map(new ClassWithoutNoArgConstructor(_))).map(_.x).collect()
- assert (control == result.toSeq)
+ assert (control === result.toSeq)
}
override def beforeAll() {