flink checkpoint/savepoint的metad
2021-09-03 本文已影响0人
星辰fml
源头
flink的checkpoint和savepoint用于恢复作业状态,在恢复作业时,如果存在多个checkpoint,将获取最新的checkpoint来进行恢复,没有checkpoint,将使用savepoint来进行恢复。
在savepoint和checkpoint中最重要的当属于metadata文件了,下面将介绍metadata文件内容格式:
metadata 由于
文件组成
metadata由3部分组成:
- Headers
- MasterState
-
OperatorState
structure
Headers

MasterState

OperatorState

