Flink之状态管理及容错机制

一、状态管理的基本概念 1.1、什么是状态 　　首先举一个无状态计算的例子：消费延迟计算。 假设现在有一个消息队列，消息队列中有一个生产者持续往消费队列写入消息，多个消费者分别从消息队列中读取消息。从图上可以看出，生产者已经写入 16 条消息，Offset 停留在 15 ；有 3 个消费者，有的消费快，而有的消费慢。消费快的已经消费了 13 条数据，消费者慢的才消费了 7、8 条数据。 如何实时统

>>阅读原文<<