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

请问flinkcdc中监听sqlserver数据,程序只在启动时读取了表数据,新插入了一条没读取到。

请问flinkcdc中监听sqlserver数据,程序只在启动时读取了表数据,新插入了一条没读取到啥情况?

展开
收起
十一0204 2023-07-19 17:17:23 162 0
1 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    在 Flink CDC 中,如果您使用的是 SQL Server CDC 连接器,程序只在启动时读取了表数据,而没有读取新插入的数据,可能是由于以下原因导致的:

    CDC 连接器配置错误
    您需要确保 SQL Server CDC 连接器的配置正确无误。请检查您的 CDC 连接器配置,包括数据库连接信息、表信息和列信息等,确保它们与实际情况相符。

    CDC 连接器版本问题
    您需要使用支持 SQL Server CDC 的 Flink CDC 连接器版本。请检查您正在使用的 Flink CDC 连接器版本是否支持 SQL Server CDC,并尝试使用最新版本的 Flink CDC 连接器。

    CDC 连接器运行状态问题
    如果 CDC 连接器的运行状态不正确,可能会导致无法读取新插入的数据。请检查 CDC 连接器的运行状态,并确保它正常运行。

    数据库事务问题
    如果新插入的数据在 Flink CDC 启动之后被插入到数据库中,但未被 Flink CDC 捕获到,可能是由于数据库事务问题引起的。在某些情

    2023-07-29 20:16:25
    赞同 展开评论 打赏

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

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载