Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
flink sql tumble window 时区问题
Classic
List
Threaded
♦
♦
Locked
1 message
hailong
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
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/
Free forum by Nabble
Edit this page