问题一:如果Flink CDC 不用 CTAS 怎么把分库分表的 库名和表名同步过来?
如果Flink CDC 不用 CTAS 怎么把分库分表的 库名和表名同步过来?
参考答案:
“MySQL CDC Source支持元数据列语法” 搜索
请参考此文档https://help.aliyun.com/zh/flink/developer-reference/mysql-connector?spm=a2c4g.11174283.0.i2
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/597866?spm=a2c6h.12873639.article-detail.97.50e24378TRW91E
问题二:在使用Flink CDC从MySQL进行实时同步至目标库的场景中,如何解决生产环境中的问题?
在使用Flink CDC从MySQL进行实时同步至目标库的场景中,如何解决生产环境中由于MySQL连接数过多而造成的源数据库压力过大的问题?特别是在Flink 3.0版本下,针对运行在YARN上的任务管理(而非Kubernetes),以及对于存量客户可能存在的SQL自定义需求和资源管理的案例呢?
参考答案:
可以考虑升级到CDC3.0版本。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/597668?spm=a2c6h.12873639.article-detail.98.50e24378TRW91E
问题三:flink cdc pipeline配置文件那种sink支持MySQL吗?
flink cdc pipeline配置文件那种sink支持MySQL吗?就是想从一个mysql 同步到另一个mysql 。一直报这个错怎么解决?
参考答案:
不支持。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/596411?spm=a2c6h.12873639.article-detail.99.50e24378TRW91E
问题四:Flink CDC里这个错误怎么解决?
Flink CDC里这个错误怎么解决? 最新版的连接器,换了旧版的没报这个错误了,报新错误了说找不到这个类
Caused by: java.lang.ClassNotFoundException: org.apache.doris.flink.tools.cdc.DateToStringConverter
参考答案:
1.4 DateToStringConvert是放在cdc目录下。1.5 放在了cdc.mysql下面。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/596410?spm=a2c6h.12873639.article-detail.100.50e24378TRW91E
问题五:flink cdc 2.4.2版本,去读分布式mysql的会报连接超时的问题怎么解决?
flink cdc 2.4.2版本,去读分布式mysql的会报连接超时的问题怎么解决?The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.从2.4.0升级到2.4.2后报的。
参考答案:
这种一般是mysql 的wait_timeout链接超时导致,活跃下空闲链接就行了,调下点,connection.time.out 。参数cdc的connect.timeout 。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/596408?spm=a2c6h.12873639.article-detail.101.50e24378TRW91E