Re:回复: Flink SQL 时间问题

2019-09-03 文章 hb
kafka输入: {"eventTime": 10, "id":1,"name":"hb"} 错误提示: ``` Caused by: java.lang.Exception: java.io.IOException: Failed to deserialize JSON object. at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.checkThrowSourceExecutionException(SourceStreamTask.java

回复: Flink SQL 时间问题

2019-09-03 文章 Jimmy Wong
Hi: 时间你可以转成Long,关于UTC,你说要生成Table,这样的话如果用的是SQL,可以采用UDF进行转换 | | Jimmy | | wangzmk...@163.com | 签名由网易邮箱大师定制 在2019年09月3日 21:25,JingsongLee 写道: Hi: 1.是的,目前只能是UTC,如果你有计算要求,你可以考虑改变的业务的窗口时间。 2.支持long的,你输入是不是int才会报错的,具体报错的信息? Best, Jingsong Lee