Flink容錯機制-雙十一神話的安全保障

Flink容錯機制以及Chandy-Lamport算法 流式計算分爲有狀態和無狀態兩種情況，所謂狀態就是計算過程中的中間值； 對於無狀態計算，會獨立觀察每個獨立事件，並根據最後一個事件輸出結果：對於一個流式系統接收到一系列的數字，當數字大於N則輸出，這時候在此之前的數字的值、和等情況，壓根不關心，只和最後這個大於N的數字相關就行； 有狀態計算：想求過去一分鐘所有數字的和或者平均數等，這種就需要保存

>>阅读原文<<