flink sql tumble window 时区问题

Wed, 24 Feb 2021 20:22:09 -0800 

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/

回复