开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

flinkcdc在mysql cdc同步时, 为什么执行时使用的不同这个id?

flinkcdc在mysql cdc同步时,cdc ddl的属性里指定了server-id, insert语句里也指定了server-id, 例如 insert into table_a select from cdc_table /+ OPTIONS('server-id'='6410') */; 为什么执行时使用的不同这个id?我同步一个库20多张表,指定同一个server-id的话会报one or more fetcher,指示server-id冲突。我对20多张表都配置了不同的server-id,不会报冲突,但作业运行时,实际使用的不同配置的server-id,而是同一个server-id

展开
收起
夹心789 2024-05-28 17:38:09 57 0
0 条回答
写回答
取消 提交回答

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

相关电子书

更多
搭建电商项目架构连接MySQL 立即下载
搭建4层电商项目架构,实战连接MySQL 立即下载
PolarDB MySQL引擎重磅功能及产品能力盛大发布 立即下载

相关镜像