Flink笔记(二十):Flink 之 State 状态介绍

1.State介绍 Flink 架构体系的一大特性是:有状态计算。 有状态计算:任务执行过程中,会存储计算过程中产生的中间结果,并提供后续的 Function 或 算子计算结果使用 状态:任务内部数据(计算数据和元数据属性)的快照。在计算过程中会进行持久化,保存有任务中间计算结果的数据。 2.State作用 1、实时任务每次计算,需要基于上一次计算结果,所以需要通过 State 将任务每次计算的中间结果进行持久化。 2、任务执行出现错误时,需要从成功的检查点(CheckPoint)中,根据 State 数据进行恢复 3、Flink 增量计算、Fa