首页
学习
活动
专区
圈层
工具
发布
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    【Flink】【更新中】状态后端和checkpoint

    根据状态的不同访问方式,有如下两种重新分配的模式: Even-split redistribution: 每个算子都保存一个列表形式的状态集合,整个状态由所有的列表拼接而成。...图片 Union redistribution: 每个算子保存一个列表形式的状态集合。整个状态由所有的列表拼接而成。作业恢复或重新分配时,每个算子都将获得所有的状态数据。...Union redistribution 模式下 checkpoint metadata会存储每个operator 的 subTask 的offset信息。...如果List State的基数较大时,不要使用这种方式的redistribution。因为容易引起OOM。 图片 调用不同的获取状态对象的接口,会使用不同的状态分配算法。...redistribution 算法。

    84030
    领券