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

在Flink CDC中数据量太大 第一次全量同步咋整 ?

在Flink CDC中数据量太大 第一次全量同步咋整 ?

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

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

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

高性能

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

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

在Flink CDC中明明有创建如下,但是使用同步消费kafka中数据的时候,会显示报错?

在Flink CDC中明明有创建 Topic :tidb_tmp_sync_cdc 但是使用kafka-sync-table同步消费kafka中数据的时候,显示Could not get metadata from server?请参考图片:

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

在Flink CDC中可以写好同步代码 打包jar包 然后上传到flink web界面的吗?

在Flink CDC中可以写好同步代码 打包jar包 然后上传到flink web界面的submit new job吗?

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

在Flink CDC中MySQL整库同步,Kafka Pipeline 不支持指定 分区吗?

在Flink CDC中MySQL整库同步,Kafka Pipeline 不支持指定 topic 分区 key吗?

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

在Flink CDC中pgsql cdc同步,pgsql的user需要哪些权限呢?

在Flink CDC中pgsql cdc同步,pgsql的user需要哪些权限呢?

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

在Flink CDC中凌晨的时候要对前一天的数据进行汇总计算。 那请问怎么判断前一天数据已经同步完成

在Flink CDC中凌晨的时候要对前一天的数据进行汇总计算。 那请问怎么判断前一天数据已经同步完成?

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

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

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

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

在Flink CDC中同步oracle的时候 报这个错,怎么解决?

在Flink CDC中同步oracle的时候 报这个错,怎么解决?Caused by: io.debezium.DebeziumException: The db history topic or its content is fully or partially missing. Please check database history topic configuration and re-....

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

在Flink CDC中tinyint(1) 类型数据好像同步有问题,如何解决?

在Flink CDC中tinyint(1) 类型数据好像同步有问题,如何解决?请参考图片:

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

产品推荐

阿里云实时计算Flink

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

+关注