[
https://issues.apache.org/jira/browse/FLINK-25411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463642#comment-17463642
]
Surendra Lalwani commented on FLINK-25411:
------------------------------------------
[~MartijnVisser] I am using Session cluster for deploying my Flink Job on Yarn,
I am reading from Kafka and performing simple query on that which I mentioned
above in the description and them I try to dump that data into Kafka, but
before dumping I need to use JSONRowSerializationSchema to convert my Row into
JSON. While doing that I get error to include JSR310 module into my classpath.
When I tried changing code for JSONRowSerializationSchema and added modules
(JSR310Module and JAvaTimeModule), then it worked fine, I am looking for more
appropriate solution.
> JsonRowSerializationSchema unable to parse TIMESTAMP_LTZ fields
> ---------------------------------------------------------------
>
> Key: FLINK-25411
> URL: https://issues.apache.org/jira/browse/FLINK-25411
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream, API / Type Serialization System
> Reporter: Surendra Lalwani
> Priority: Minor
>
> While I try to fire a simple query Select current_timestamp from table_name ,
> it gives error that Could not serialize row and asks me to add shaded flink
> dependency for jsr-310. Seems like in the Serializer , the JavaTimeModule is
> not added
--
This message was sent by Atlassian Jira
(v8.20.1#820001)