Flink状态管理和容错机制介绍

导读:本文来自8月11日在北京举行的 Flink Meetup会议，分享来自于施晓罡，目前在阿里大数据团队部从事Blink方面的研发，如今主要负责Blink状态管理和容错相关技术的研发

本文主要内容以下：

• 有状态的流数据处理；
• Flink中的状态接口；
• 状态管理和容错机制实现；
• 阿里相关工做介绍；

一.有状态的流数据处理

1.1.什么是有状态的计算

计算任务的结果不单单依赖于输入，还依赖于它的当前状态，其实大多数的计算都是有状态的计算。 好比wordcount,给一些word,其计算它的count,这是一个很常见的业务场景。count作为输出，在计算的过程当中要不断的把输入累加到count上去，那么count就是一个state。

1.2.传统的流计算系统缺乏对于程序状态的有效支持

• 状态数据的存储和访问；
• 状态数据的备份和恢复；
• 状态数据的划分和动态扩容；

01.jpg