Flink学习(三)状态机制于容错机制,State与CheckPoint

摘自Apache官网   一、State的基本概念 什么叫State?搜了一把叫做状态机制。可以用作以下用途。为了保证 at least once, exactly once,Flink引入了State和Checkpoint 某个task/operator某时刻的中间结果 快照(snapshot) 程序一旦crash,恢复用的 机器学习模型的参数   二、Flink中包含的State Keyed
相关文章
相关标签/搜索