Hi: 时间你可以转成Long,关于UTC,你说要生成Table,这样的话如果用的是SQL,可以采用UDF进行转换
| | Jimmy | | wangzmk...@163.com | 签名由网易邮箱大师定制 在2019年09月3日 21:25,JingsongLee<lzljs3620...@aliyun.com.INVALID> 写道: Hi: 1.是的,目前只能是UTC,如果你有计算要求,你可以考虑改变的业务的窗口时间。 2.支持long的,你输入是不是int才会报错的,具体报错的信息? Best, Jingsong Lee ------------------------------------------------------------------ From:hb <343122...@163.com> Send Time:2019年9月3日(星期二) 10:44 To:user-zh <user-zh@flink.apache.org> Subject:Flink SQL 时间问题 使用kafka connectorDescriptor , 从kafka读取json格式数据, 生成Table ``` ... schema.field("_proctime", Types.SQL_TIMESTAMP()).proctime() schema .field("_rowtime", Types.SQL_TIMESTAMP()) .rowtime( new Rowtime() .timestampsFromField("eventTime") .watermarksPeriodicBounded(1000) ) ``` 问题1. 生成的 _proctime 处理时间字段, 结果显示的时区是UTC, 怎么调整成 +8时区. 问题2. eventTime 事件时间字段怎么支持Long类型. 我输入到kafka记录为 {"eventTime": 100000, "id":1,"name":"hb"} 会提示 eventTime 字段类型问题