Hi
我理解应该是任务恢复的时候从上一次成功的 checkpoint 或者你指定的 checkpoint 里记录的 offset 开始消费,所以此时的统计值应该是有短暂的下跌,因为数据相当于回复到之前重复计算了一部分。这个应该是符合预期的,可能需要在业务上做一些处理。 Best JasonLee ---- 回复的原邮件 ---- | 发件人 | 天下五帝东<xudongjun123...@163.com> | | 发送日期 | 2022年10月10日 13:34 | | 收件人 | user-zh@flink.apache.org<user-zh@flink.apache.org> | | 主题 | Flink sql从ck恢复,统计数据波动问题 | Hi: 各位大佬们,flink任务从状态恢复时,统计值有一个明显的下跌,等ck打完后,统计值才会上升,这种情况有什么好的解决方案吗?