diff --git a/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala b/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala index 9e3d2451fcd19..b952e953b1425 100644 --- a/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala +++ b/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala @@ -340,6 +340,7 @@ object SparkExecuteStatementOperation { case _: StringType => TTypeId.STRING_TYPE case _: DecimalType => TTypeId.DECIMAL_TYPE case DateType => TTypeId.DATE_TYPE + case _: TimeType => TTypeId.STRING_TYPE // TODO: Shall use TIMESTAMPLOCALTZ_TYPE, keep AS-IS now for // unnecessary behavior change case TimestampType => TTypeId.TIMESTAMP_TYPE diff --git a/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/ThriftServerQueryTestSuite.scala b/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/ThriftServerQueryTestSuite.scala index 047e4b8c99602..a249d4b4d4e44 100644 --- a/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/ThriftServerQueryTestSuite.scala +++ b/sql/hive-thriftserver/src/test/scala/org/apache/spark/sql/hive/thriftserver/ThriftServerQueryTestSuite.scala @@ -110,9 +110,7 @@ class ThriftServerQueryTestSuite extends SQLQueryTestSuite with SharedThriftServ "pipe-operators.sql", // VARIANT type "variant/named-function-arguments.sql", - "variant-field-extractions.sql", - // SPARK-51516: Support the TIME data type by Thrift Server - "time.sql" + "variant-field-extractions.sql" ) override def runQueries(