开发者社区 问答 正文

Apache中在Flink的分布式快照方法运行时每个节点传到barrier后,接下来做了什么?

Apache中在Flink的分布式快照方法运行时每个节点传到barrier后,接下来做了什么?

展开
收起
游客qemwegwo2hhpy 2021-12-07 21:51:10 1108 分享 版权
1 条回答
写回答
取消 提交回答
  • 1、Source保存其输入数据的offsets
    2、算子保存其state
    3、事务型Sink节点对已有事务提交pre-commoit

    2021-12-07 21:52:18
    赞同 展开评论