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

flink cdc增量同步mysql,怎么样才能提高用户速度呢?

flink cdc增量同步mysql,怎么样才能提高用户速度呢?

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

Flink CDC里cdc整库同步,全量初始化过程超过binlog的保存时间会不会导致数据丢失啊?

Flink CDC里cdc整库同步,全量初始化过程超过binlog的保存时间会不会导致数据丢失啊?

高性能

Flink CDC 实现企业级实时数据同步

传统的数据集成通常由全量和增量同步两套系统构成,在全量同步完成后,还需要进一步将增量表和全量表进行合并操作,这种架构的组件构成较为复杂,系统维护困难。本方案提供 Flink CDC 技术实现了统一的增量和全量数据的实时集成。
技术解决方案背景图
问答 2024-02-01 来自:开发者社区

使用flink cdc同步数据,当一个表进行了表结构变更,除了修改成 latest,怎么解决?

使用flink cdc同步数据,当一个表进行了表结构变更,我这边做了flink cdc重启之后就会出现Caused by: org.apache.kafka.connect.errors.ConnectException: Data row is smaller than a column index, internal schema representation is probably out....

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

Flink CDC里cannl 同步oracle的binlog 技术成熟吗?

Flink CDC里cannl 同步oracle的binlog 技术成熟吗?

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

Flink CDC里 我用flink SQL 同步一张表到es。日志不动,没有报错怎么排查?

Flink CDC里 我用flink SQL 同步一张表到es。 tasks 状态 一直卡在 DEPLOYING日志到这里就不动了:2024-01-23 22:15:38,787 INFO com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner [] - Split table skill_...

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

Flink CDC里我用cdc同步mysql数据到mysql,想增加一个表结构变更的通知,该怎么做?

Flink CDC里我用cdc同步mysql数据到mysql,想增加一个表结构变更的通知,这个该怎么实现呢?有相似的实现吗?

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

Flink CDC里为什么我在用flinkcdc3同步mysql到doris的时候语句不同步?

Flink CDC里为什么我在用flinkcdc3同步mysql到doris的时候,delete语句无法同步呢?

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

Flink CDC里flink1.18同步mysql-starrocks pipeline什么问题?

Flink CDC里flink1.18同步mysql-starrocks pipeline这是什么问题?

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

Flink CDC里请问整库同步有文档吗? 是不是只支持 mysql ?

Flink CDC里请问整库同步有文档吗? 是不是只支持 mysql ?

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

Flink CDC里cdc 同步 PG的数据,会对线上业务库性能影响很大么?

Flink CDC里 同步 PG的数据,为了获取 delete/update 操作,需要 [ALTER TABLE reptest REPLICA IDENTITY FULL;] ,业务库需要所有表都同步的话,会对线上业务库性能影响很大么?

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

产品推荐

阿里云实时计算Flink

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

+关注