Skip to content

Commit 2cff2b2

Browse files
committed
address comment
1 parent 160e406 commit 2cff2b2

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

sql/core/src/test/scala/org/apache/spark/sql/QueryTest.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -313,12 +313,12 @@ object QueryTest {
313313
isSorted: Boolean = false): Option[String] = {
314314
if (prepareAnswer(expectedAnswer, isSorted) != prepareAnswer(sparkAnswer, isSorted)) {
315315
val getRowType: Option[Row] => String = row =>
316-
"RowType" + row.map(row =>
316+
row.map(row =>
317317
if (row.schema == null) {
318-
"[]"
318+
"struct<>"
319319
} else {
320-
s"[${row.schema.fields.map(_.dataType.typeName).mkString(",")}]"
321-
}).getOrElse("[]")
320+
s"${row.schema.catalogString}"
321+
}).getOrElse("struct<>")
322322

323323
val errorMessage =
324324
s"""

0 commit comments

Comments
 (0)