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") { |