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 2a1867f67c17827e1af5c2370c1fe3b8b7079698..a6e3bd3a91a15555be42f127ef4bb23fe432f3bf 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") {