本质需求是写一套mysql的flink source。要基于新source接口,但是因为比较急怎么办

本质需求是写一套mysql的flink source。要基于新source接口,但是因为比较急,新source接口实现比较复杂。发现flink cdc中mysql的source实现了新source接口,所以准备改造一下flink cdc只读全量数据。

这个Flink CDC source端一直都是繁忙状态,只有没有数据写入mysql来才会颜色下降,

这个Flink CDC source端一直都是繁忙状态,只有没有数据写入mysql来才会颜色下降,是哪儿有参数没配置吗?

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

1 课时 |
204 人已学 |
免费

RDS MySQL 高效设计及性能调优

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

flink-cdc 在抽取mysql binlog,运行一段时间 source 就报java.uti

flink-cdc 在抽取mysql binlog,运行一段时间 source 就报java.util.concurrent.CompletionException: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableE...

请教各位大佬,使用MySQL CDC source读取数据的时候,如果用sqlclient提交任务,

请教各位大佬,使用MySQL CDC source读取数据的时候,如果用sqlclient提交任务,如何设置能让多个表使用一个数据源读取?就是我可能同时同步100多个表,不想在mysql端建立100多个同步连接。。。

一个mysql表,做两个source,serverId设置成不一样的范围值是否会报serveID重复

一个mysql表,做两个source,serverId设置成不一样的范围值是否会报serveID重复呢?

ADB-MYSQL报这个错是啥意思呀 source input is invalid 在查数据的时

ADB-MYSQL报这个错是啥意思呀 source input is invalid 在查数据的时候

大佬们, source oracle sink mysql是用flinkSql稳定还是用Stream

大佬们, source oracle sink mysql是用flinkSql稳定还是用Stream稳定?

请问一下flink cdc mysql source 报这种错怎么处理呢?我都设置了useSSL=f

请问一下flink cdc mysql source 报这种错怎么处理呢?我都设置了useSSL=false了。。在本地没问题 放到k8s上面就这样了

大佬们,我有一个MySQL source 通过旁路分流分了两个流,然后转表,现在想sink到两个hb

大佬们,我有一个MySQL source 通过旁路分流分了两个流,然后转表,现在想sink到两个hbase表,该怎么处理呢

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

产品推荐

社区圈子

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

云数据库 RDS MySQL 版source相关内容