Flink——容錯機制

Flink的容錯機制 概述 Flink容錯的核心機制就是持續地創建分佈式數據流及其狀態的一致性快照，。當系統遇到故障時，比如（機器，網絡，軟件等），重啓所有的算子，回退到checkpoint（檢查點），確保程序的每一條記錄只會作用準確一次(exactly-once )的語義，也可以選擇配置成至少一次(at-least-once ) 注意： 爲了容錯機制生效，數據源（例如 queue 或者 brok

>>阅读原文<<