Flink笔记(十八):Flink 之 StateBackend 介绍 & 使用

oooohaozi 20 0 PDF 2021-01-17 01:01:58

1.StateBackEnd 用来保存 State 的存储后端就叫做StateBackend。StateBackend 默认是保存在 JobManager 的内存中,也可以保存在 本地文件系统 或者 HDFS 分布式文件系统中。 当检查点(CheckPoint)机制启动时,状态将在检查点中持久化来应对数据的丢失以及恢复。而1.状态在内部是如何表示的? 2.状态是如何持久化到检查点中以及3.持久化到哪里都取决于选定的StateBackend。 2.可用的StateBackEnd Flink为我们提供了如下三种Statebackend实现: 1. Mem

用户评论
请输入评论内容
评分:
暂无评论