请问flinkcdc中改了后,为什么一直打印这个?我这里是mysql 出问题了吗?

问题1:7814216685e47e9094afa1fe9b302a3e.jpg
请问flinkcdc中改了后,为什么一直打印这个?我这里是mysql 出问题了吗?还是哪里出问题了?能关闭这个校验,还是说这个是做什么操作的?
问题2:mysql啊,我只是改写成多数据源,表那里没改的。实例名字.表名_*,这里写到tablelist。

展开
收起
十一0204 2023-07-19 17:25:54 148 分享 版权
2 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    我需要更多的上下文信息才能为您提供准确的答案。但是,如果您在 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 连续打印错误消息。

    2023-07-29 20:09:33
    赞同 展开评论
  • 意中人就是我呀!

    "回答:1:5bbc5ab6e4e3ff3adadff48f106f5a99.png
    这是在找表,没事。你是oracle?此回答整理至钉群“Flink CDC 社区”。
    "

    2023-07-19 18:41:20
    赞同 展开评论

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

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