flink1.3.5 cdc版本是2.1 flinkcdc任务跑着跑着 报这个错误了?session这个参数就是定时重启一下logminer,查看oracle 执行历史,重启logminer也执行了,但是该会话的内存依然一直在涨Caused by: org.apache.flink.runtime.checkpoint.CheckpointException: Could not complete snapshot 347685 for operator Source: TableSourceScan 有朋友碰到过么?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
网络问题:如果 CDC 任务涉及到网络通信,例如从远程数据库读取数据,网络不稳定或断开可能导致任务失败。
数据库连接问题:如果 CDC 任务连接到的数据库出现问题,例如连接超时或连接丢失,可能会导致任务失败。
资源问题:如果 CDC 任务使用的资源(例如内存、CPU)不足,可能会导致任务失败。
针对这个问题,您可以尝试以下方法:
检查网络连接是否正常,确保 CDC 任务能够正常连接到所需的数据库。
检查数据库连接是否正常,确保 CDC 任务能够正常读取数据。
检查任务所需的资源是否足够,例如内存、CPU 等。
尝试升级 Flink 版本和 CDC 版本,以查看是否存在已知的问题或错误修复。Flink 1.3.5 是一个比较老的版本,可能存在一些已知的问题。
如果问题仍然存在,可以尝试增加 CDC 任务的并行度或调整任务的配置参数,例如增加检查点的时间间隔等。