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打完后,统计值才会上升,这种情况有什么好的解决方案吗?

回复