Flink State状态以及Checkpoint机制（二）

在上篇文章中介绍了如何Flink的State状态，本篇文章接着上篇文章继续介绍Flink的Checkpoint机制。启动checkpoint机制它能够为每个job备份了一份快照，当job遇到故障重启或者失败的时候，咱们就没必要从每一个job的源头去从新计算，而是从最近的一个完整的checkpoint开始恢复，避免了重复计算，节省了资源，而且保证了Exactly Once 语义。具体的使用方法以及实

>>阅读原文<<