Flink之狀態管理及容錯機制

一、狀態管理的基本概念 1.1、什麼是狀態 　　首先舉一個無狀態計算的例子：消費延遲計算。 假設現在有一個消息隊列，消息隊列中有一個生產者持續往消費隊列寫入消息，多個消費者分別從消息隊列中讀取消息。從圖上可以看出，生產者已經寫入 16 條消息，Offset 停留在 15 ；有 3 個消費者，有的消費快，而有的消費慢。消費快的已經消費了 13 條數據，消費者慢的才消費了 7、8 條數據。 如何實時統

>>阅读原文<<