FlinkFlink 1.13 版本 SavePoint 源码分析

Posted 2022-09-23 九师兄

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了FlinkFlink 1.13 版本 SavePoint 源码分析相关的知识，希望对你有一定的参考价值。

1.概述

本章节主要讲解 Flink 1.13 版本 SavePoint 源码分析，对于Flink 1.9版本触发检查点的详细信息可以参考：【Flink】Flink 使用代码如何主动触发 SavePoint

触发SavePoint的源码位于 EmbeddedJobClient#stopWithSavepoint

@Override
    public CompletableFuture<String> stopWithSavepoint(
            final boolean

以上是关于FlinkFlink 1.13 版本 SavePoint 源码分析的主要内容，如果未能解决你的问题，请参考以下文章