天天看点

flink的operator state简单理解

  1. 每个子任务都有自己的状态,子任务之间的状态互相隔离,互不影响
  2. 每个子任务的状态一般都是列表的形势,相当于子列表
  3. 持久化存储的时候会把每个子任务的子列表组合起来,组成一个大的列表的结构
  4. 当任务失败重启的时候或者任务并行度变化的时候,从持久化存储中恢复数据
  5. 从持久化存储中恢复数据时,会把大的列表按照任务的并行度进行拆分,拆分成一个个子列表的形式分配给各个子任务
  6. 子任务获取到属于自己的子列表状态数据后,状态恢复完成

继续阅读