diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DaysWritable.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DaysWritable.scala index 486f678e49d7..56c176e024ac 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DaysWritable.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DaysWritable.scala @@ -54,7 +54,9 @@ class DaysWritable( } override def getDays: Int = julianDays - override def get(): Date = new Date(DateWritable.daysToMillis(julianDays)) + override def get(doesTimeMatter: Boolean): Date = { + new Date(DateWritable.daysToMillis(julianDays, doesTimeMatter)) + } override def set(d: Int): Unit = { gregorianDays = d diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveSerDeReadWriteSuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveSerDeReadWriteSuite.scala index f8ba7bf2c1a6..10a0cdb76036 100644 --- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveSerDeReadWriteSuite.scala +++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveSerDeReadWriteSuite.scala @@ -184,4 +184,12 @@ class HiveSerDeReadWriteSuite extends QueryTest with SQLTestUtils with TestHiveS checkComplexTypes(fileFormat) } } + + test("SPARK-32594: insert dates to a Hive table") { + withTable("table1") { + sql("CREATE TABLE table1 (d date)") + sql("INSERT INTO table1 VALUES (date '2020-08-11')") + checkAnswer(spark.table("table1"), Row(Date.valueOf("2020-08-11"))) + } + } }