diff --git a/sql/core/src/test/scala/org/apache/spark/sql/CollationSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/CollationSuite.scala index da8aad16f55d2..031bf337cec90 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/CollationSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/CollationSuite.scala @@ -947,7 +947,10 @@ class CollationSuite extends DatasourceV2SQLBase with AdaptiveSparkPlanHelper { withTable(table) { sql(s"create table $table (a array) using parquet") sql(s"insert into $table values (array('aaa')), (array('AAA'))") - checkAnswer(sql(s"select distinct a from $table"), Seq(Row(Seq("aaa")))) + val result = sql(s"select distinct a from $table").collect() + assert(result.length === 1) + val data = result.head.getSeq[String](0) + assert(data === Array("aaa") || data === Array("AAA")) } // map doesn't support aggregation withTable(table) { @@ -968,7 +971,10 @@ class CollationSuite extends DatasourceV2SQLBase with AdaptiveSparkPlanHelper { withTable(table) { sql(s"create table $table (s struct) using parquet") sql(s"insert into $table values (named_struct('fld', 'aaa')), (named_struct('fld', 'AAA'))") - checkAnswer(sql(s"select s.fld from $table group by s"), Seq(Row("aaa"))) + val result = sql(s"select s.fld from $table group by s").collect() + assert(result.length === 1) + val data = result.head.getString(0) + assert(data === "aaa" || data === "AAA") } }