Flink CDC中job cancel后，能从checkpoint 恢复吗？[阿里云实时计算 Flink版] 暂停朗读为您朗读

Flink CDC 中的 job 在取消后，是否能从检查点恢复取决于几个因素：

1. 是否开启了检查点：如果没有配置和开启检查点，那么无法从检查点进行恢复。

2. 检查点策略：如果使用基于时间驱动的检查点策略（例如每隔 2 分钟保存一次），那么在取消 job 后可能会丢失最近的检查点数据。如果使用基于状态驱动的检查点策略（例如流状态大小超过 1GB 时保存一次），那么可能可以恢复到最近的检查点。

3. 检查点目录是否被删除：如果手动删除了存储检查点的目录，那么将无法从检查点进行恢复。

4. 检查点目录的磁盘空间：确保有足够的磁盘空间来存储检查点数据。

综上所述：

– 如果开启了状态驱动的检查点，并且检查点目录没有被删除，并且有足够的磁盘空间存储检查点数据，那么在取消 job 后可以通过从最新的检查点进行恢复来重新启动 job。

– 如果仅使用时间驱动的检查点，并且在取消 job 时没有保存最后一个检查点，那么无法从检查点进行恢复。

要实现从检查点进行恢复，需要进行以下配置：

1. 开启检查点，并选择适当的检查点策略（状态驱动或时间驱动）。 2. 配置正确的检查点路径，并确保有足够的磁盘空间存储检查点数据。 3. 在重新启动 job 时，使用 execution.checkpointing.restore = latest 选项来指定从最新的检查点进行恢复。

请注意，以上配置可以让 Flink CDC job 在取消后能够从最新的检查点进行恢复。

配置了检查点就可以，没配置就不行，此回答整理自钉群“Flink CDC 社区”