Flink CDC2.4.1版本,新加表之后,新加的表采集完全量,整个任务又卡住不继续读数据了?

Flink CDC2.4.1版本,新加表之后,新加的表采集完全量,整个任务又卡住不继续读数据了?image.png
image.png
initial,scan.incremental.snapshot.enabled=true,新加的这张表全量采集结束了,全量采集的时候之前的表的增量也在同步进行,但是快照阶段结束之后就卡住了,一直输出Binlog offset on checkpoint 4156: {ts_sec=0, file=mysql-bin-changelog.110547, pos=2073785, kind=SPECIFIC, gtids=, row=0, event=0},我用的是mvn终于仓库下载来的2.4.1版本image.png

展开
收起
真的很搞笑 2023-08-01 14:47:28 158 分享 版权
2 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    如果在 Flink CDC 2.4.1 版本中,新加的表采集完全量后,整个任务卡住不继续读数据了,可能是由于以下原因之一导致的:

    数据库连接超时
    如果您在使用 Flink CDC 时,数据库连接超时,可能会导致任务卡住不继续读数据。您可以尝试增加数据库连接的超时时间,或者优化数据库连接的性能,以提高任务的稳定性。

    Flink CDC 配置错误
    如果您在使用 Flink CDC 时,配置文件中存在错误配置,可能会导致任务卡住不继续读数据。您可以检查配置文件中的参数是否正确,并尝试调整参数,以提高任务的稳定性。

    数据库表结构发生变化
    如果您在使用 Flink CDC 时,数据库表结构发生变化,可能会导致任务卡住不继续读数据。您可以尝试重新启动任务,以重新加载数据库表结构。

    程序代码异常
    如果您在使用 Flink CDC 时,程序代码存在异常,可能会导致任务卡住不继续读数据。您可以检查程序代码,并尝试修复异常,以提高任务的稳定性。

    2023-08-01 23:01:30
    赞同 展开评论
  • 采集source的代码看看,配的什么策略,此回答整理自钉群“Flink CDC 社区”

    2023-08-01 15:02:12
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理