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

  1. 云栖社区>
  2. 阿里云实时计算>
  3. 博客>
  4. 正文

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

巴蜀真人 2019-08-05 17:26:46 浏览3514
展开阅读全文

作者:孙梦瑶
整理:韩非

本文主要分享内容如下:

  • 状态管理的基本概念;
  • 状态的类型与使用示例;
  • 容错机制与故障恢复;

一.状态管理的基本概念

1.什么是状态

1

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

如何实时统计每个消费者落后多少条数据,如图给出了输入输出的示例。可以了解到输入的时间点有一个时间戳,生产者将消息写到了某个时间点的位置,每个消费者同一时间点分别读到了什么位置。刚才也提到了生产者写入了 15 条,消费者分别读取了 10、7、12 条。那么问题来

网友评论

登录后评论
0/500
评论
巴蜀真人
+ 关注
所属云栖号: 阿里云实时计算