Flink SQL时间序列化问题

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Flink SQL时间序列化问题

guaishushu1103@163.com
Flink-1.12.0 SQL定义timestamp(3)格式出现时间解析问题

CREATE TABLE
user_log1 (    
user_id string,  
 ts TIMESTAMP(3),  
  proc_time as PROCTIME()) WITH (


Caused by: java.io.IOException: Failed to deserialize JSON '{"user_id":"1188","ts":"2021-02-19T17:52:20.921Z"}'.
at org.apache.flink.formats.json.JsonRowDataDeserializationSchema


[hidden email]