You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "Karim Ramadan (Jira)" <ji...@apache.org> on 2024/11/20 10:52:00 UTC
[jira] [Created] (SPARK-50364) Row.jsonValue is not able to serialize LocalDateTime
Karim Ramadan created SPARK-50364:
-------------------------------------
Summary: Row.jsonValue is not able to serialize LocalDateTime
Key: SPARK-50364
URL: https://issues.apache.org/jira/browse/SPARK-50364
Project: Spark
Issue Type: Bug
Components: SQL
Affects Versions: 3.5.3
Reporter: Karim Ramadan
Trying to serialize to JSON a Row containing a column of type _TimestampNTZType_ ({_}LocalDateTime{_}) with methods:
{code:java}
def json: String = compact(jsonValue)
def prettyJson: String = pretty(render(jsonValue))
{code}
Will fail with:
{code:java}
[FAILED_ROW_TO_JSON] Failed to convert the row value '2018-05-14T12:13' of the class class java.time.LocalDateTime to the target SQL type "TIMESTAMPNTZTYPE" in the JSON format. SQLSTATE: 2203G
org.apache.spark.SparkIllegalArgumentException: [FAILED_ROW_TO_JSON] Failed to convert the row value '2018-05-14T12:13' of the class class java.time.LocalDateTime to the target SQL type "TIMESTAMPNTZTYPE" in the JSON format. SQLSTATE: 2203G
at org.apache.spark.sql.Row.toJson$1(Row.scala:663)
at org.apache.spark.sql.Row.toJson$1(Row.scala:651)
at org.apache.spark.sql.Row.jsonValue(Row.scala:665)
at org.apache.spark.sql.Row.jsonValue$(Row.scala:598)
at org.apache.spark.sql.catalyst.expressions.GenericRow.jsonValue(rows.scala:28)
at org.apache.spark.sql.RowJsonSuite.$anonfun$testJson$1(RowJsonSuite.scala:41)
{code}
This happens because the toJson method inside of the class is missing a serializer for the LocalDateTime type
{code:java}
def toJson(value: Any, dataType: DataType): JValue = (value, dataType) match {
case (null, _) => JNull
case (b: Boolean, _) => JBool(b)
case (b: Byte, _) => JLong(b)
case (s: Short, _) => JLong(s)
case (i: Int, _) => JLong(i)
case (l: Long, _) => JLong(l)
...
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org