From e4d2162a2d443c0e9790e1f3592c73fc93f213c7 Mon Sep 17 00:00:00 2001 From: Max Gekk Date: Thu, 3 Jul 2025 15:49:50 +0200 Subject: [PATCH] Support TIME by the Thrift server --- .../hive/thriftserver/SparkExecuteStatementOperation.scala | 1 + .../sql/hive/thriftserver/ThriftServerQueryTestSuite.scala | 4 +--- 2 files changed, 2 insertions(+), 3 deletions(-) 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(