回复： Flink SQL 时间问题

[Jimmy Wong]

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 字段类型问题