Flink原理(五)——容错机制

1.  前言      流式计算分为有状态和无状态两种状况,所谓状态就是计算过程当中的中间值。对于无状态计算,会独立观察每一个独立事件,并根据最后一个事件输出结果。什么意思?大白话举例:对于一个流式系统,接受到一系列的数字,当数字大于N则输出,这时候在此以前的数字的值、和等状况,压根不关心,只和最后这个大于N的数字相关,这就是无状态计算。什么是有状态计算了?想求过去一分钟内全部数字的和或者平均数等
相关文章
相关标签/搜索