开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

关于Flink CDC,这种情况为什么ck会卡住?

问个问题,pgsql通debezium.snapshot.select.statement.overrides和debezium.snapshot.select.statement.overrides.[schema].[table]参数限定了数据范围,导致某些表在任务启动的时候没有数据,这种情况下ck似乎卡住了,我对照了一下,没有完成的ck的表是没有数据的 图片.png

展开
收起
游客uu65yiq7myioi 2023-01-08 17:59:03 339 0
1 条回答
写回答
取消 提交回答
  • Flink CDC 中的 Checkpoint 卡住可能是由多种因素造成的。以下是可能导致这种情况的一些常见原因:

    WAL 日志写入延迟:如果源数据库的 WAL 日志写入延迟,Flink CDC 连接器可能无法及时获取新事件,从而导致 Checkpoint 无法完成。

    2024-02-27 17:43:33
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Apache Flink 案例集(2022版) 立即下载
    ClickHouse在手淘流量分析应用实践Jason Xu 立即下载
    云数据库clickhouse最佳实践 立即下载