源头
flink的checkpoint和savepoint用于恢复作业状态,在恢复作业时,如果存在多个checkpoint,将获取最新的checkpoint来进行恢复,没有checkpoint,将使用savepoint来进行恢复。
在savepoint和checkpoint中最重要的当属于metadata文件了,下面将介绍metadata文件内容格式:
metadata 由于
文件组成
metadata由3部分组成:
- Headers
- MasterState
-
OperatorState
structure
Headers
![](https://img.haomeiwen.com/i10136051/727295bde80aaf26.png)
MasterState
![](https://img.haomeiwen.com/i10136051/826c2877e9bd1ee1.png)
OperatorState
![](https://img.haomeiwen.com/i10136051/f28ace3afc25fa34.png)
![](https://img.haomeiwen.com/i10136051/e8107e62ef69dc05.png)
网友评论