[ 
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)

Reply via email to