Apache Flink 進(jìn)階（三）：Checkpoint 原理解析與應(yīng)用實(shí)踐

作者：唐云(茶干)

大家好，今天我將跟大家分享一下 Flink 里面的 Checkpoint，共分為四個(gè)部分。首先講一下 Checkpoint 與 state
的關(guān)系，然后介紹什么是 state，第三部分介紹如何在 Flink 中使用state，第四部分則介紹 Checkpoint 的執(zhí)行機(jī)制。

Checkpoint 與 state 的關(guān)系

Checkpoint 是從 source 觸發(fā)到下游所有節(jié)點(diǎn)完成的一次全局操作。下圖可以有一個(gè)對 Checkpoint
的直觀感受，紅框里面可以看到一共觸發(fā)了 569K 次 Checkpoint，然后全部都成功完成，沒有 fail 的。



state 其實(shí)就是 Checkpoint 所做的主要持久化備份的主要數(shù)據(jù)，看下圖的具體數(shù)據(jù)統(tǒng)計(jì)，其 state 也就 9kb 大小 。



什么是 state

我們接下來

• ? 上一篇： CentOS 7 設(shè)置日系統(tǒng)時(shí)間為中國時(shí)區(qū)并啟用NTP同步
• ? 下一篇：人生，還沒困難到"非死不可"