flink之檢查點（checkpoint）和保存點（savepoint）的區別

一、檢查點：檢查點屏障跟普通記錄一樣。它們由算子處理，但並不參與計算，而是會觸發與檢查點相關的行爲。會在算子之間流動。當讀取輸入流的數據源遇到檢查點屏障時，它將其在輸入流中的位置保存到穩定存儲中。如果輸入流來自消息傳輸系統（Kafka 或 MapR Streams），這個位置就是偏移量。Flink 的存儲機制是插件化的，穩定存儲可以是分佈式文件系統，如HDFS、S3 或 MapR-FS 如圖所示，

>>阅读原文<<