Skip to content

Commit a408ab9

Browse files
committed
Fix SparkThriftServerProtocolVersionsSuite
1 parent f5e692a commit a408ab9

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/SparkThriftServerProtocolVersionsSuite.scala

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -362,11 +362,13 @@ class SparkThriftServerProtocolVersionsSuite extends HiveThriftServer2TestBase {
362362
}
363363

364364
test(s"$version get interval type") {
365-
testExecuteStatementWithProtocolVersion(version, "SELECT interval '1' year '2' day") { rs =>
365+
testExecuteStatementWithProtocolVersion(
366+
version,
367+
"SELECT CAST('1 year 2 day' AS INTERVAL) AS icol") { rs =>
366368
assert(rs.next())
367369
assert(rs.getString(1) === "1 years 2 days")
368370
val metaData = rs.getMetaData
369-
assert(metaData.getColumnName(1) === "INTERVAL '1 years 2 days'")
371+
assert(metaData.getColumnName(1) === "icol")
370372
assert(metaData.getColumnTypeName(1) === "string")
371373
assert(metaData.getColumnType(1) === java.sql.Types.VARCHAR)
372374
assert(metaData.getPrecision(1) === Int.MaxValue)

0 commit comments

Comments
 (0)