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

请问下，CDC 同步mysql到iceberg时，只要 mysql库中部分表的部分字段，如何实现？

请问下，CDC 同步mysql到iceberg时，只要 mysql库中部分表，部分表的部分字段，有没有好的方案可以精准控制

展开

收起

wenti 2023-02-27 11:23:46 232 版权

2 条回答

写回答

取消提交回答

665661

cli的话，最后那个插入语句可以控制吧。——该回答整理自钉群“Flink CDC 社区”

2023-02-27 22:08:47

赞同展开评论
凌云Cloud

发表文章、提出问题、分享经验、结交志同道合的朋友

使用 Flink SQL 语句对表和字段进行过滤就可以了

2023-02-27 12:19:32

赞同展开评论

问答分类：

关系型数据库 MySQL 云数据库 RDS MySQL 版

问答标签：

云数据库 RDS MySQL 版库云数据库 RDS MySQL 版字段云数据库 RDS MySQL 版同步 cdc云数据库 RDS MySQL 版 cdc云数据库 RDS MySQL 版字段

问答地址：

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

相关问答

实时计算 Flink版

请教各位大佬，flink cdc同步mysql数据到iceberg，iceberg有50个表，然后要

140

请教个问题，flink cdc同步mysql数据到iceberg。任务运行一段时间后，表的结构改了（

140

对于Flink CDC，mysql分库分表入iceberg的V2表，任务重启时为啥历史数据重复写入？

401

在从mysql合宽表（left join）到iceberg的时候，iceberg commit 记录

387

大佬们请问有没有flink cdc 同步mysql写入iceberg的demo[感谢]

588

flink cdc(mysql) -> elasticsearch7, 任务每次持续跑了一段时间之后

1232

请教下有flink cdc 对接mysql5.6的demo么？我这边显示各种包错误

1171

flink1.13.5 mysql-cdc-2.2.0 mysql 5.6 一次同步90w数据后不同

354

mysql cdc与changelog_json都能适配flink1.15吗?

558

大家有测试过一个脚本采用flink cdc 同步mysql 能同时同步多少表吗 ?

2135

大数据与机器学习

实时计算 Flink

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

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

MySQL的查询操作语法要点

基于springboot的旅游门票预定系统

基于springboot的4s店汽车试驾销售服务系统

基于非支配排序遗传算法NSGAII的综合能源优化调度（Matlab代码实现）

HikariCP 高性能数据库连接池技术详解与实践指南

请问下，CDC 同步mysql到iceberg时，只要 mysql库中部分表的部分字段，如何实现？

实时计算 Flink

相关文章

热门讨论

热门文章