Flink状态管理之checkPoint

简介 一、state通常指一个具体的task/operator的状态【state数据默认保存在java的堆内存中】,而checkpoint【能够理解为checkpoint是把state数据持久化存储了】,则表示了一个Flink Job在一个特定时刻的一份全局状态快照,即包含了全部task/operator的状态java 注意:task是Flink中执行的基本单位。operator指算子(trans
相关文章
相关标签/搜索