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 a534edfa..aefb0134 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