You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by we...@apache.org on 2016/04/22 17:07:26 UTC
spark git commit: [SPARK-14848][SQL] Compare as Set in DatasetSuite -
Java encoder
Repository: spark
Updated Branches:
refs/heads/master 92675471b -> 5bed13a87
[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 <ro...@gmail.com>
Closes #12610 from robbinspg/DatasetSuiteFix.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/5bed13a8
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/5bed13a8
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/5bed13a8
Branch: refs/heads/master
Commit: 5bed13a872dc06d099c810cf4caa15b4f27a1e7c
Parents: 9267547
Author: Pete Robbins <ro...@gmail.com>
Authored: Fri Apr 22 23:07:12 2016 +0800
Committer: Wenchen Fan <we...@databricks.com>
Committed: Fri Apr 22 23:07:12 2016 +0800
----------------------------------------------------------------------
sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/5bed13a8/sql/core/src/test/scala/org/apache/spark/sql/DatasetSuite.scala
----------------------------------------------------------------------
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 2a1867f..a6e3bd3 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") {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org