源頭
flink的checkpoint和savepoint用于恢復(fù)作業(yè)狀態(tài),在恢復(fù)作業(yè)時,如果存在多個checkpoint鞋诗,將獲取最新的checkpoint來進(jìn)行恢復(fù),沒有checkpoint迈嘹,將使用savepoint來進(jìn)行恢復(fù)削彬。
在savepoint和checkpoint中最重要的當(dāng)屬于metadata文件了,下面將介紹metadata文件內(nèi)容格式:
metadata 由于
文件組成
metadata由3部分組成:
- Headers
- MasterState
-
OperatorState