Hi: 1.是的，目前只能是UTC，如果你有计算要求，你可以考虑改变的业务的窗口时间。 2.支持long的，你输入是不是int才会报错的，具体报错的信息？
Best, Jingsong Lee ------------------------------------------------------------------ From:hb <[email protected]> Send Time:2019年9月3日(星期二) 10:44 To:user-zh <[email protected]> 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 字段类型问题
