Flink CDC里在mysql库中新增一个mysql表之后,flink-sql就挂了是为啥?

Flink CDC里在mysql库中新增一个mysql表之后,flink-sql就挂了:2024-04-19 10:47:32,715 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: ods_xxx_c...

Flink CDC里mysql cdc 正则匹配需要抽取的表 抽取任务启动后 怎么实现这个目标?

Flink CDC里mysql cdc 正则匹配需要抽取的表 抽取任务启动后 有通过添加什么配置 新增的表也能捕获抽取到呢?我说的是任务不重启 能自动感知新增的表 进行抽取?

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

RDS MySQL 高效设计及性能调优

1 课时 |
802 人已学 |
免费
开发者课程背景图

如何保障flink cdc采集任务能在MySQL 多个备库中?

如何保障flink cdc采集任务能在MySQL 多个备库中?如果当前备库挂了,能随意切换到另一个备库的。

Flink CDC这边需要做一个mysql到mysql的整库实时同步请问有什么好的第三方工具推荐吗?

Flink CDC这边需要做一个mysql到mysql的整库实时同步(源库可能出现表或字段变动,备库也需跟着变动),请问有什么好的第三方工具推荐吗?

Flink CDC里 mysql cdc 的op_ts 时间binlog是毫秒,是哪个参数控制的?

Flink CDC里 mysql cdc 的op_ts 时间binlog是毫秒,但是到kakfa里面变成了 秒,是哪个参数控制的? sql过去的 ,flink-cdc

Flink CDC里我有张mysql表,配置的是init,每次都是同步一条数据,然后就不同步了为啥?

Flink CDC里我有张mysql表,配置的是init,试了好几次,每次都是同步一条数据,然后就不继续同步数据了,可能是啥原因?从最新的biglog同步,没啥问题.checkpoint 是成功的就个别表会出现无法增量同步这种问题,也没看出是啥规律?有没有排查这个问题方向?都没有数据进来,recei...

flink cdc 怎么程序化初始化时候一次拿全量mysql单表数据,启动之后使用binlog监控?

flink cdc 怎么程序化初始化的时候一次拿全量mysql单表数据,启动之后使用binlog监控?每次程序启动,以前未消费的数据,广播数据都还没全到底,就把用户数据消费了,导致了漏数据.

请教下flink cdc 1.17 、cdc-2.4.1 同步mysql数据使用 出错为啥?

请教下flink cdc 1.17 、cdc-2.4.1 同步mysql数据使用 'scan.startup.mode' = 'timestamp'出现这种错误可能是什么原因?io.debezium.DebeziumException: Encountered change event for ta...

Flink CDC里mysql到doris报这个错为啥?

Flink CDC里mysql到doris报这个错为啥?

Flink CDC里这里是mysql到SR 这里可以将数据整到同一张表中嘛?

Flink CDC里这里是mysql到SR 大佬这里要是用正则整库多张表的数据,这里可以将数据整到同一张表中嘛?这里的对应关系在那个参数里体现啊?这里是sink端嘛 ?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

社区圈子

阿里云数据库
阿里云数据库
让用户数据永远在线,让数据无缝的自由流动
279459+人已加入
加入
相关电子书
更多
PolarDB-X:更具性价比的 MySQL替换
2023云栖大会:AnalyticDB MySQL新特性介绍
2023云栖大会:云数据库RDS - 年度产品发布与最佳实践
立即下载 立即下载 立即下载
相关镜像

云数据库 RDS MySQL 版更多cdc相关