美文网首页
flink checkpoint/savepoint的metad

flink checkpoint/savepoint的metad

作者: 星辰fml | 来源:发表于2021-09-03 12:14 被阅读0次

源头

flink的checkpoint和savepoint用于恢复作业状态,在恢复作业时,如果存在多个checkpoint,将获取最新的checkpoint来进行恢复,没有checkpoint,将使用savepoint来进行恢复。
在savepoint和checkpoint中最重要的当属于metadata文件了,下面将介绍metadata文件内容格式:
metadata 由于

文件组成

metadata由3部分组成:

  • Headers
  • MasterState
  • OperatorState


    structure

Headers

header

MasterState

MasterState

OperatorState

OperatorState types

相关文章

网友评论

      本文标题:flink checkpoint/savepoint的metad

      本文链接:https://www.haomeiwen.com/subject/xlqkwltx.html