问题1:
请问flinkcdc中改了后,为什么一直打印这个?我这里是mysql 出问题了吗?还是哪里出问题了?能关闭这个校验,还是说这个是做什么操作的?
问题2:mysql啊,我只是改写成多数据源,表那里没改的。实例名字.表名_*,这里写到tablelist。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
我需要更多的上下文信息才能为您提供准确的答案。但是,如果您在 Flink CDC 中修改了某些配置或代码后,Flink CDC 一直打印错误消息,可能是以下原因之一:
配置错误
如果您更改了 Flink CDC 的配置,例如更改了 MySQL 数据库的连接信息或更改了表的列信息,但是配置错误,Flink CDC 可能无法正确连接到 MySQL 数据库或读取正确的数据。这可能导致 Flink CDC 连续打印错误消息。
代码错误
如果您修改了 Flink CDC 的代码,例如更改了 CDC 数据源的行解析器或更改了 CDC 任务的处理逻辑,但是代码错误,Flink CDC 可能无法正确解析或处理 CDC 数据。这可能导致 Flink CDC 连续打印错误消息。
数据库问题
如果您使用的是 MySQL 数据库,并且在 Flink CDC 运行时出现了连接问题或其他 MySQL 数据库问题,例如网络故障或数据库崩溃,Flink CDC 可能无法正确读取 MySQL 数据库中的数据。这可能导致 Flink CDC 连续打印错误消息。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。