Flink流計算編程--Flink擴容、程序升級先後的思考

對於持續生成新數據的場景，採用流計算顯然是有利的。數據源源不斷的產生，流計算系統理論上就要不間斷的提供數據計算（能夠停機維護的場景不在本文的討論範圍）。那麼假如遇到下面的幾種狀況，流計算是如何保證數據的一致性的呢？css 一、應用程序bug修復，即功能的修改 二、應用程序增長、刪除新的功能 三、流計算框架版本的升級 四、突發的大量數據的到來 以上列出的幾種狀況，我相信在大多數的流數據場景下，

>>阅读原文<<