Skip to content

Commit 74b59ff

Browse files
committed
Update SQLQuerySuite.scala
1 parent e237541 commit 74b59ff

File tree

1 file changed

+12
-1
lines changed

1 file changed

+12
-1
lines changed

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

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3746,7 +3746,7 @@ class SQLQuerySuite extends QueryTest with SharedSparkSession with AdaptiveSpark
37463746
}
37473747
}
37483748

3749-
test("SPARK-33593: Parquet vector reader incorrect with binary partition value") {
3749+
test("SPARK-33593: Vector reader got incorrect data with binary partition value") {
37503750
Seq("false", "true").foreach(value => {
37513751
withSQLConf(SQLConf.PARQUET_VECTORIZED_READER_ENABLED.key -> value) {
37523752
withTable("t") {
@@ -3758,6 +3758,17 @@ class SQLQuerySuite extends QueryTest with SharedSparkSession with AdaptiveSpark
37583758
Row("a", "Spark SQL", "Spark SQL"))
37593759
}
37603760
}
3761+
3762+
withSQLConf(SQLConf.ORC_VECTORIZED_READER_ENABLED.key -> value) {
3763+
withTable("t") {
3764+
sql(
3765+
"""CREATE TABLE t(name STRING, id BINARY, part BINARY)
3766+
|USING ORC PARTITIONED BY (part)""".stripMargin)
3767+
sql("INSERT INTO t PARTITION(part = 'Spark SQL') VALUES('a', X'537061726B2053514C')")
3768+
checkAnswer(sql("SELECT name, cast(id as string), cast(part as string) FROM t"),
3769+
Row("a", "Spark SQL", "Spark SQL"))
3770+
}
3771+
}
37613772
})
37623773
}
37633774
}

0 commit comments

Comments
 (0)