Flink的容错机制

1 状态一致性       当在分布式系统中引入状态时,自然引入了一致性问题。一致性实际上是“正确性级别”的另一种说法,也就是说在成功处理故障并恢复之后得到的结果,与没有发生任何故障时得到的结果相比,前者到底有多正确?举例来说,假设要对最近一小时登录的用户计数。在系.统经历故障之后,计数结果是多少?如果有偏差,是有漏掉的计数还是重复计数? 1.1 基本概念       有状态的流处理,内部算子任务
相关文章
相关标签/搜索