请问flinkcdc中监听sqlserver数据,程序只在启动时读取了表数据,新插入了一条没读取到啥情况?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
在 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 捕获到,可能是由于数据库事务问题引起的。在某些情
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。