FLinkFlink checkpoint 实现数据连续计算 恢复机制 案例实战

Posted 2021-08-30 九师兄

1.概述

本博客是视频：https://www.bilibili.com/video/BV1yk4y1z7Lr?p=26&spm_id_from=pageDriver 的笔记。

2. 案例

2.1 没有checkpoint

/**
 * 项目名称: Apache Flink 知其然，知其所以然 - upgrade
 * 功能描述: 演示开启Checkpoint之后,failover之后可以从失败之前的状态进行续跑。
 * 操作步骤:
 *        1. 直接运行程序，failover之后，聚合值可以从新计算。
 *        2. 开启Checkpoint之后，failover之后 聚合值基于原有状态进行续跑。
 *        3. 改变日志级别，我们看一下Checkpoint数据跑哪里去了(No state backend | failover regions.)
 *        4. 方便查看，修改日志WARNÿ