From c5470f328a788e5be7919eeb173d30c62013bb3a Mon Sep 17 00:00:00 2001 From: liulijia Date: Tue, 18 Jun 2024 21:38:28 +0800 Subject: [PATCH] [fix](compatible) Fix cast eror when select data from doris 2.0 --- .../src/main/scala/org/apache/doris/spark/sql/Utils.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/Utils.scala b/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/Utils.scala index 89103892..7cffbe56 100644 --- a/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/Utils.scala +++ b/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/Utils.scala @@ -25,7 +25,7 @@ import org.apache.spark.sql.sources._ import org.slf4j.Logger import java.sql.{Date, Timestamp} -import java.time.Duration +import java.time.{Duration, LocalDate} import java.util.concurrent.locks.LockSupport import scala.annotation.tailrec import scala.reflect.ClassTag @@ -106,6 +106,7 @@ private[spark] object Utils { case stringValue: String => s"'${escapeSql(stringValue)}'" case timestampValue: Timestamp => "'" + timestampValue + "'" case dateValue: Date => "'" + dateValue + "'" + case dateValue: LocalDate => "'" + dateValue + "'" case arrayValue: Array[Any] => arrayValue.map(compileValue).mkString(", ") case _ => value }