Flink检查点备份方法和装置

本公开提出一种Flink检查点备份方法和装置，方法包括：获取Flink任务的任务标识信息及检查点存储根路径；遍历检查点存储根路径下的快照文件，筛选出有效快照文件，并基于有效快照文件的快照序列号及任务标识信息进行增量识别与去重校验，将通过校验的有效快照文件的文件全路径与任务标识信息组装为备份任务消息，推送至分布式缓存的缓冲队列；并派发给对应消费线程池中的空闲工作线程；通过空闲工作线程解析备份任务消息，构建冗余备份目标路径，以进行跨存储冗余备份。由此，通过有效快照文件的增量识别与去重校验、跨存储冗余复制，实现了无需停止Flink任务即可完成的检查点备份，并消除了单点存储故障风险。