diff options
author | Pete Robbins <robbinspg@gmail.com> | 2016-04-22 23:07:12 +0800 |
---|---|---|
committer | Wenchen Fan <wenchen@databricks.com> | 2016-04-22 23:07:12 +0800 |
commit | 5bed13a872dc06d099c810cf4caa15b4f27a1e7c (patch) | |
tree | 78054119a8d7234c2b6207dd6357db750388e816 | |
parent | 92675471b72d313160bf05e1cafd68ee9220e7ea (diff) | |
download | spark-5bed13a872dc06d099c810cf4caa15b4f27a1e7c.tar.gz spark-5bed13a872dc06d099c810cf4caa15b4f27a1e7c.tar.bz2 spark-5bed13a872dc06d099c810cf4caa15b4f27a1e7c.zip |
[SPARK-14848][SQL] Compare as Set in DatasetSuite - Java encoder
## What changes were proposed in this pull request?
Change test to compare sets rather than sequence
## How was this patch tested?
Full test runs on little endian and big endian platforms
Author: Pete Robbins <robbinspg@gmail.com>
Closes #12610 from robbinspg/DatasetSuiteFix.
-rw-r--r-- | sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala index 2a1867f67c..a6e3bd3a91 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala @@ -456,8 +456,8 @@ class DatasetSuite extends QueryTest with SharedSQLContext { implicit val kryoEncoder = Encoders.javaSerialization[JavaData] val ds = Seq(JavaData(1), JavaData(2)).toDS() - assert(ds.groupByKey(p => p).count().collect().toSeq == - Seq((JavaData(1), 1L), (JavaData(2), 1L))) + assert(ds.groupByKey(p => p).count().collect().toSet == + Set((JavaData(1), 1L), (JavaData(2), 1L))) } test("Java encoder self join") { |