Flink流计算编程--Flink扩容、程序升级先后的思考

对于持续生成新数据的场景，采用流计算显然是有利的。数据源源不断的产生，流计算系统理论上就要不间断的提供数据计算（能够停机维护的场景不在本文的讨论范围）。那么假如遇到下面的几种状况，流计算是如何保证数据的一致性的呢？css 一、应用程序bug修复，即功能的修改 二、应用程序增长、删除新的功能 三、流计算框架版本的升级 四、突发的大量数据的到来 以上列出的几种状况，我相信在大多数的流数据场景下，

>>阅读原文<<