You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by xuhaiLong <xi...@163.com> on 2021/02/25 04:21:51 UTC

flink sql tumble window 时区问题

hi all：
    
    使用flink sql发现一个时区问题，在flink 1.11.3，flink 1.10 都有发现。


使用eventtime，datestream 转换为table，对times字段使用 rowtime。数据为 1614218400000，执行完rowtime 后变成 1614189600000 直接就少了8小时，导致后续的开窗都有问题。


代码参考：https://paste.ubuntu.com/p/xYpWNrR9MT/