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 38a60ff [fix](connector) fix read date type convert issue (#253)
38a60ff is described below
commit 38a60ff18505f03bdbdcbd40dd74243f26066d43
Author: gnehil <[email protected]>
AuthorDate: Tue Jan 7 09:52:22 2025 +0800
[fix](connector) fix read date type convert issue (#253)
---
.../src/main/scala/org/apache/doris/spark/util/RowConvertors.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/RowConvertors.scala
b/spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/RowConvertors.scala
index a534edf..aefb013 100644
---
a/spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/RowConvertors.scala
+++
b/spark-doris-connector/spark-doris-connector-base/src/main/scala/org/apache/doris/spark/util/RowConvertors.scala
@@ -109,7 +109,7 @@ object RowConvertors {
dataType match {
case StringType => UTF8String.fromString(v.asInstanceOf[String])
case TimestampType =>
DateTimeUtils.fromJavaTimestamp(Timestamp.valueOf(v.asInstanceOf[String]))
- case DateType =>
DateTimeUtils.fromJavaDate(Date.valueOf(v.asInstanceOf[String]))
+ case DateType => DateTimeUtils.fromJavaDate(v.asInstanceOf[Date])
case _: MapType =>
val map = v.asInstanceOf[Map[String, String]]
val keys = map.keys.toArray
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
