阿里云文档 2026-04-27

Flink CDC Transform模块

本文向您介绍Flink CDC数据摄入作业的 Transform 模块支持的语法规则及内置函数。

阿里云文档 2026-04-09

Flink CDC Pipeline模块

本文向您介绍Flink CDC数据摄入作业支持的全局配置项。您可以在pipeline模块中配置以下选项。

阿里云文档 2026-02-03

基于Flink CDC构建复杂业务场景案例

本文为您介绍在源端表结构变更、数据逻辑增强(注入元数据/计算列/逻辑删除)、异构路由(分表合并、整库同步)及精准管控(表过滤、时间戳启动)等复杂业务场景下使用Flink CDC数据摄入作业的最佳实践。

阿里云文档 2026-02-02

基于Flink CDC实现实时分发

本文为您介绍使用数据摄入YAML作业将实时数据写入常用消息队列的最佳实践。

阿里云文档 2025-08-07

Flink CDC作业结构

本文将向您介绍基于Flink CDC的数据摄入作业的基本结构及重要参数。

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

请问一下 Flink CDC 方式同步,目标数据量比源数据偏多问题

同步方式:PIPELINE source源:mysql sink源:starrocks 问题:初始化同步后,部分starrock表的数据比抽取的mysql源表还多 特点:mysql业务库使用了seata中间件做分布式事务,有物理删除行为

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

在Flink CDC中,发到kafka下游再处理数据还是用算子处理完直接写到目标库里面?

在Flink CDC中,发到kafka下游再处理数据还是用算子处理完直接写到目标库里面?

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

在Flink CDC中同步Mysql数据,数据能全部同步到目标,只是过一段时间后 任务会报错为什么?

在Flink CDC中同步Mysql数据,数据能全部同步到目标,只是过一段时间后 任务会报错,请问是什么原因?请参考图片:

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

在Flink CDC中现在可以同步mysql的表结构变化,但是如何将表结构变化同步到目标呢?

在Flink CDC中现在可以同步mysql的表结构变化,但是如何将表结构变化同步到目标postgrep端呢?

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

在Flink CDC中对数据的修改变更会以新的记录形式写到目标表,为什么不是在目标表中修改数据呢?

在Flink CDC中flink 1.7.2模式 yarn-session flink SQL使用flink-sql-connector-cdc-oracle-3.1.0flink-connector-jdbc-3.1.2-1.17SQL 配置如下,可以实现数据全量同步,新增数据同步,删除数据同步,但是对数据的修改变更会以新的记录形式写到目标表,为什么不是在目标表中修改数据呢?请参考图片:

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注