Flink CDC这问题要怎么处理?

Flink CDC这问题要怎么处理?image.png

展开
收起
真的很搞笑 2023-08-01 14:55:32 89 分享 版权
2 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    该错误的含义是您配置的CDC连接器有一个与您的主从复制拓扑中的另一个MySQL仆人/副本冲突的server-id。

    可能的情况有:

    您 mistakenly将相同的server-id配置给CDC连接器和另一个MySQL副本。 每个副本/仆人的server-id必须是唯一的。

    您复用了先前由另一个已移除的副本使用过的server-id。 MySQL 会记住曾经连接过它的副本的server-ids。

    3.错误代码1236表明这是一个server-id冲突错误。

    解决方法是:

    为CDC连接器配置一个唯一的且未被其他MySQL副本使用过的server-id。 server-id最好是一个大于1的整数。

    您可以运行以下查询来查看MySQL当前使用的server-id:

    sql
    Copy
    SELECT FROM mysql.slave_master_info;
    SELECT
    FROM mysql.slave_relay_log_info;
    然后再为CDC连接器配置一个不同的唯一server-id。

    总的来说,为避免server-id冲突,需要确保CDC连接器配置的server-id与MySQL集群中的所有其他副本 configuration都不同。

    2023-08-01 19:29:21
    赞同 展开评论
  • 用不同的server-id,此回答整理自钉群“Flink CDC 社区”

    2023-08-01 15:05:20
    赞同 展开评论

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

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