开发者社区 问答 正文

flink1.3.5 cdc版本是2.1 flinkcdc任务跑着跑着 报这个错误了?session

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 有朋友碰到过么?

展开
收起
真的很搞笑 2023-04-19 17:59:26 214 分享 版权
1 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    网络问题:如果 CDC 任务涉及到网络通信,例如从远程数据库读取数据,网络不稳定或断开可能导致任务失败。

    数据库连接问题:如果 CDC 任务连接到的数据库出现问题,例如连接超时或连接丢失,可能会导致任务失败。

    资源问题:如果 CDC 任务使用的资源(例如内存、CPU)不足,可能会导致任务失败。

    针对这个问题,您可以尝试以下方法:

    检查网络连接是否正常,确保 CDC 任务能够正常连接到所需的数据库。

    检查数据库连接是否正常,确保 CDC 任务能够正常读取数据。

    检查任务所需的资源是否足够,例如内存、CPU 等。

    尝试升级 Flink 版本和 CDC 版本,以查看是否存在已知的问题或错误修复。Flink 1.3.5 是一个比较老的版本,可能存在一些已知的问题。

    如果问题仍然存在,可以尝试增加 CDC 任务的并行度或调整任务的配置参数,例如增加检查点的时间间隔等。

    2023-07-10 07:51:07
    赞同 展开评论
收录在圈子:
实时计算 Flink 版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,拥有全球统一商业化品牌,完全兼容开源 Flink API,提供丰富的企业级增值功能。
还有其他疑问?
咨询AI助理