可以试试添加使用Continuou Trigger Yun Tang <myas...@live.com> 于2021年10月29日周五 下午5:56写道：
> Hi， > > 先问个版本问题，你的Flink版本是1.3 而不是1.13？ > > > Checkpoint里面会存储timer，所以重启之后会触发窗口的计算，但确实这种一天的窗口累计有点太多了，除非你的作业存在比较严重的反压，导致checkpoint内积攒了大量没有触发的timer。 > > 祝好 > 唐云 > > ________________________________ > From: claylin <1012539...@qq.com.INVALID> > Sent: Friday, October 29, 2021 11:33 > To: user-zh <user-zh@flink.apache.org> > Subject: 关于作业失败从checkpoint重启，触发了过期的窗口计算 > > > 作业失败后从checkpoint重启，重启后会触发之前已经过期的时间窗口计算，求问这个该怎么解决。我的运行环境是flink1.3/1.4+sql举例：作业每小时做一次checkpoint，状态设置了1小时过期，状态后端使用rocksdb，同时使用了一天的滚动时间窗口，然后今天15点30分重启，但是重启后会有昨天的窗口计算结果触发。 > 按理说不应该会触发已经过期的窗口计算，而且flink 1.3/1.4 > 下 state.backend.rocksdb.timer-service.factory 这个配置默认是rocksdb， > 也就是说rocksdb里面存储了状态的有效时间， > 不管怎么样也不应该触发已经过期的窗口计算， > 请问大家有没有遇到过这种问题，怎么解决。 >
