flink异常恢复

[王金海]

讨论下flink异常重启问题

从kafka消费数据，checkpoint周期在5分钟，如果在第6分钟，因为异常导致flink任务重启，flink是从上个checkpoint恢复呢？还是从异常时的offset恢复呢？



csbl...@163.com
Have a nice day !