Flink CDC任务从savepoint/checkpoints状态中恢复作业错误问题
初步排查是因为chpoints中_metadata中记录的binlog文件与数据库当前写入的binlog(SHOW MASTER STATUS查看;)文件不一样导致的,_metadata中正确记录保存了当前监听位置即pos,但是所对应的binlog file却是错误的,把检查点目录、保存点目录删掉,监听配置从指定timestamp改为latest,重新启动作业,然后取消作业再从检查点恢复作业,可以正常恢复。但是为什么一开始checkpoint没有正确记录保存当前监听位置pos所对应的binlog文件,而是记录了错误的binlog文件到_metadata中,这一点还不知道原因,不知道如何排查,但是可能binlog文件截断和跨binlog记录事务有关,可以参考https://blog.csdn.net/kjh2007abc/article/details/85001048
赞179
踩0