tongchenkeji 发表于:2023-11-6 12:13:560次点击 已关注取消关注 关注 私信 Flink数据源就是mysql到mysql。不知道有没有整库同步的支持?[阿里云实时计算 Flink版] 暂停朗读为您朗读 Flink数据源就是mysql到mysql。不知道有没有整库同步的支持? 「点点赞赏,手留余香」 赞赏 还没有人赞赏,快来当第一个赞赏的人吧! 海报 实时计算Flink版# MySQL1179# 云数据库 RDS MySQL 版1517# 关系型数据库2577# 实时计算 Flink版3179# 流计算2236
xin在这AM 2023-11-27 18:30:27 1 mysql的cdc connector支持多表的读,但jdbc connector应该是不支持多表的写。 所以一条语句完成应该不行, 你可以代码里面把库下的表列出来用statementSet添加多条语句执行,flink on k8s有人使用kubectl apply -f xx.yaml的方式提交任务的经验吗。 可否不用flink客户端(run-application)而使用apply -f 的方式类似于提交application模式的job上k8s,此回答整理自钉群“【③群】Apache Flink China社区”
小周sirAM 2023-11-27 18:30:27 2 Flink支持MySQL to MySQL的数据同步,具体可以通过以下步骤实现: 安装Flink CDC插件,连接源MySQL数据库; 创建Flink CDC Source,定义源表和目标表; 编写SQL语句,实现数据同步; 启动Flink任务,开始数据同步。需要注意的是,在同步数据时需要注意MySQL的连接参数,确保源表和目标表之间有足够的资源进行同步。
mysql的cdc connector支持多表的读,但jdbc connector应该是不支持多表的写。 所以一条语句完成应该不行, 你可以代码里面把库下的表列出来用statementSet添加多条语句执行,flink on k8s有人使用kubectl apply -f xx.yaml的方式提交任务的经验吗。 可否不用flink客户端(run-application)而使用apply -f 的方式类似于提交application模式的job上k8s,此回答整理自钉群“【③群】Apache Flink China社区”
Flink支持MySQL to MySQL的数据同步,具体可以通过以下步骤实现:
需要注意的是,在同步数据时需要注意MySQL的连接参数,确保源表和目标表之间有足够的资源进行同步。