This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-spark-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 1df1c96 [fix](compatible) Fix cast eror when select data from doris
2.0 (#209)
1df1c96 is described below
commit 1df1c96b516cf3c5a07b61d0375edfc9eeff6801
Author: Lijia Liu <[email protected]>
AuthorDate: Wed Jun 26 17:07:59 2024 +0800
[fix](compatible) Fix cast eror when select data from doris 2.0 (#209)
---
.../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 8910389..7cffbe5 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
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
