flink异常恢复

[王金海]

讨论下flink异常重启问题

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



[hidden email]
Have a nice day !

[Jeff Zhang]

上个checkpoint

王金海 <[hidden email]> 于2019年8月27日周二 下午6:14写道：

> 讨论下flink异常重启问题
>
>
> 从kafka消费数据，checkpoint周期在5分钟，如果在第6分钟，因为异常导致flink任务重启，flink是从上个checkpoint恢复呢？还是从异常时的offset恢复呢？
>
>
>
> [hidden email]
> Have a nice day !
>
>

--
Best Regards

Jeff Zhang