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