Flink CDC里任务失败会自动清除其他机器的checkpoint文件，只保留本机的东西吗？

问题一解答：

Apache Flink 的 Checkpoint 存储机制不会自动清除其他 TaskManager 上的 Checkpoint 文件。在 Flink 集群中，Checkpoint 文件是全局共享的，这意味着当任务发生故障并需要在其他 TaskManager 上恢复时，新的 TaskManager 应该能够访问到之前存储在持久化存储上的 Checkpoint 数据。

当 TaskManager1 执行的任务失败并且 TaskManager2 接手任务时，TaskManager2 应该从集中式存储（如 HDFS、S3 或者 NFS）中读取 Checkpoint 数据进行恢复，而不是从本地磁盘查找。Flink 不会仅在本地保留 Checkpoint，而是会配置一个统一的 Checkpoint 存储目录，所有 TaskManager 都能访问这个目录。

如果在 TaskManager2 上找不到 Checkpoint 文件，可能的原因包括：

• Checkpoint 存储目录配置错误或不一致。
• Checkpoint 未成功写入到集中式存储。
• 网络问题导致 TaskManager2 无法访问集中式存储上的 Checkpoint。
• Checkpoint 已经被误删除或清理。

问题二解答：

对于 Checkpoint 文件丢失的情况，可以采取以下措施：

1. 检查配置：确认 Flink 作业的 Checkpoint 存储目录配置正确且所有 TaskManager 能够访问同一个共享目录。

2. 查看日志：查阅 Flink 作业和 TaskManager 的日志，寻找关于 Checkpoint 写入失败或读取失败的线索。

3. 手动备份恢复：如果确实有 Checkpoint 文件存在于部分 TaskManager 的本地磁盘上，可以尝试手动将其复制到正确的集中式存储位置，然后更改作业配置指向这个有效的 Checkpoint。

4. Checkpoints 清理策略：了解并确认 Flink 集群的 Checkpoint 清理策略，确保在任务失败后，有效的 Checkpoint 不会被过早地清理掉。

5. 验证存储系统健康状况：确认集中式存储系统的健康状况，确保没有 I/O 错误或其他问题阻止 Checkpoint 数据的写入和读取。

6. 维护一致性：在高可用模式下运行 JobManager 和 ZooKeeper（如果使用）以确保整个集群状态的一致性和可靠性。

checkpoint 放到 oss或 minio 上是比较靠谱的方案， 引入一个jar包就行。
https://nightlies.apache.org/flink/flink-docs-master/zh/docs/deployment/filesystems/oss/
或者你可以试试个土办法 写个定时任务 定时cp一份到其他集群。 如果是http协议 这个参数一定要加上。此回答来自钉群Flink CDC 社区。