Flink状态管理及容错机制

一. 状态管理的基本概念

1. 什么是状态

Apache Flink 零基础入门(六):状态管理及容错机制

首先举一个无状态计算的例子:消费延迟计算。假设现在有一个消息队列,消息队列中有一个生产者持续往消费队列写入消息,多个消费者分别从消息队列中读取消息。从图上可以看出,生产者已经写入 16 条消息,Offset 停留在 15 ;有 3 个消费者,有的消费快,而有的消费慢。消费快的已经消费了 13 条数据,消费者慢的才消费了 7、8 条数据。

Your browser is out-of-date!

Update your browser to view this website correctly. Update my browser now

×