文章 2024-01-04 来自:开发者社区

Flink CDC 3.0中,如果你想在同步MySQL数据时排除某列

在Flink CDC 3.0中,如果你想在同步MySQL数据时排除某列,你可以在创建Source表时使用EXCLUDE_ALL选项。以下是一个示例: CREATE TABLE source_table ( id INT, name STRING, age INT ) WITH ( 'connector' &...

问答 2024-01-01 来自:开发者社区

flink cdc 3.0 同步mysql 数据,怎么配置排除某列?

flink cdc 3.0 同步mysql 数据,怎么配置排除某列?

问答 2023-12-31 来自:开发者社区

Flink CDC sql采集mysql能拿到before的数据吗?

Flink CDC sql采集mysql能拿到before的数据吗?

问答 2023-12-31 来自:开发者社区

Flink CDC mysql无主键表需要怎么获取数据? mysql-cdc-2.4?

Flink CDC mysql无主键表需要怎么获取数据? mysql-cdc-2.4?

问答 2023-12-31 来自:开发者社区

Flink CDC这种反压怎么处理呀,代码里面就是取的mysql数据写入到doris的?

Flink CDC中,代码里面就是取的mysql数据写入到doris的,并行度是全局1,就只有一个子任务,这种反压怎么处理呀?

问答 2023-12-24 来自:开发者社区

Flink CDC 纯写sql的方式可以实现1对多关联,把mysql数据写入es么?

Flink CDC 纯写sql的方式可以实现1对多关联,把mysql数据写入es么?写入后数据长这样{ "id": 1, "name": "张三", "scoreList": [ { "id": 1, "name": "语文", "score": 90 }, { ...

问答 2023-12-24 来自:开发者社区

Flink CDC测试创建源表拉取mysql的数据还能查询,重启了sql-client后不行了?

Flink CDC测试创建源表拉取mysql的数据还能查询,重启了sql-client后不行了?

问答 2023-12-20 来自:开发者社区

flink cdc 读取MySQL数据,这种一般手动指定是u不是会规避这种情况?

在使用Flink CDC读取MySQL数据时,如果没有手动指定server-id,会报告有相同的server-id错误。一般来说,手动指定server-id可以规避这种情况。但是,手动指定server-id时如何确保与MySQL主从同步使用的不重复?又如何知道哪些server-id尚未使用?另外,为什么Flink CDC默认分配的server-id会重复?

问答 2023-12-19 来自:开发者社区

Flink CDC升级mysql cdc为2.4.0版本,对于无主键表,但是增量数据进不来?

Flink CDC升级mysql cdc为2.4.0版本,对于无主键表,通过配置【scan.incremental.snapshot.chunk.key-column】可以全量同步了,但是增量数据进不来?

问答 2023-12-12 来自:开发者社区

Flink CDC 中在获取mysql 表数据的时候,如果多张表 join 时全量获取数据吗?

ink CDC 中在获取mysql 表数据的时候,如果多张表 join 时全量获取数据还是 一批 一批获取数据? 设置debezium.min.row.count.to.stream.results 在Join能生效吗?

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