请问下flinkcdc中mysqlCDC拉取不到任何数据,是什么问题?

"问题1:af3b20cf5351bc43e080cf41d4997132.png
6728e0719622791b6361d77ab1b685ff.png
mysqlCDC拉取不到任何数据,是什么问题?
问题2:我本地这样写可以,但是拉取公司系统数据库就什么都没有,公司mysql是主从复制的,不知道是不是和这个有关?配置的是主节点。c05107a0dfdb39286d04045933e08ec1.png
权限也是满的。"

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

    如果在使用 Flink CDC 同步 MySQL 数据时,无法拉取到任何数据,可能是由于以下几个原因:

    配置错误:请确保您已正确配置了 Flink CDC 连接 MySQL 数据库的参数,包括数据库连接地址、用户名、密码、数据库名称和表格名称等。如果参数不正确,可能会导致 Flink CDC 无法连接到 MySQL 数据库,从而无法拉取数据。

    数据库权限问题:请确保您所使用的 MySQL 用户拥有足够的权限来访问和拉取数据。如果用户权限不足,可能会导致 Flink CDC 无法拉取数据。

    数据源没有新增数据:请确保您的数据源中有新增的数据,否则 Flink CDC 将无法拉取到任何数据。您可以在 MySQL 数据库中插入一些新数据,然后运行 Flink CDC,以确保 Flink CDC 正确工作并能够拉取数据。

    CDC 日志没有产生:如果您使用的是基于 MySQL binlog 技术的 Flink CDC,那么请确保 MySQL binlog 已经正确开启,并且产生了 CDC 日志。您可以在 MySQL 数据库中执行 SHOW BINARY LOGS; 命令,检查是否存在 CDC 日志。

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

    "回答1:60f5924087de132994b33483d2892c75.png
    MySQL 不用写这个,直接写表名。
    此回答整理至钉群“Flink CDC 社区”。"

    2023-07-19 17:38:14
    赞同 展开评论

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

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