Flink 修改时区负时间偏移量报错 TumblingEventTimeWindows parameters must satisfy 解决方法_start flink job failed : tumblingprocessingtimewin

作者：秋刀鱼在做梦 | 2024-08-23 03:22:12

踩

start flink job failed : tumblingprocessingtimewindows parameters must satis

报错: java.lang.IllegalArgumentException: TumblingEventTimeWindows parameters must satisfy 0 <= offset < size

由于Flink默认窗口时区是UTC-0，其他地区需要指定时间偏移量调整时区，在Flink某些低版本中(例如1.6.2等)，官方文档更新不及时，使用负时间偏移量

TumblingEventTimeWindows.of(Time.days(1),Time.hours(-8))
会出现以上报错

解决方法：
使用TumblingEventTimeWindows.of(Time.days(1),Time.hours(16))代替

注：在此 https://github.com/apache/flink/pull/5376 已经修复。最新的版本不会报错。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/秋刀鱼在做梦/article/detail/1019243