flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "JingsongLee" <lzljs3620...@aliyun.com.INVALID>
Subject Re: Flink SQL 时间问题
Date Tue, 03 Sep 2019 13:25:39 GMT
Hi:
1.是的,目前只能是UTC,如果你有计算要求,你可以考虑改变的业务的窗口时间。
2.支持long的,你输入是不是int才会报错的,具体报错的信息?

Best,
Jingsong Lee


------------------------------------------------------------------
From:hb <343122422@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 字段类型问题
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message