flink sql tumble window 时区问题

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink sql tumble window 时区问题

hailong
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/