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

在Flink CDC中数据同步过程中 mysql有几何字段 这种一般怎么同步到pg数据库呢?

在Flink CDC中数据同步过程中 mysql有几何字段 这种一般怎么同步到pg数据库呢?

文章 2024-05-23 来自:开发者社区

实时计算 Flink版产品使用合集之如何SQL同步数据到Oracle数据库中

问题一:Flink CDC中mysql源数据库有大量DML操作,怎么优化呢? Flink CDC中mysql源数据库有大量DML操作, Debezium消费数据时间落后数据生成时间 延迟几个小时。怎么优化呢? 参考答案: 在Flink CDC中,如果遇到MySQL源数据库有大量DML操作,而Debezium消费数据时间落后数据生成时间几个小时的情况,以...

实时计算 Flink版产品使用合集之如何SQL同步数据到Oracle数据库中
文章 2024-05-23 来自:开发者社区

实时计算 Flink版产品使用合集之同步数据库时,库名称变了,route只能到表级别,怎么解决

问题一:Flink CDC postgresql-cdc这两个配置有什么关系吗? Flink CDC postgresql-cdc中heartbeat.interval.ms配置与deberzium中这两个配置有什么关系吗? ...

实时计算 Flink版产品使用合集之同步数据库时,库名称变了,route只能到表级别,怎么解决
问答 2024-05-07 来自:开发者社区

Flink CDC里使用同步mysql数据时 无法指定需要的时区,只能按数据库本身的时区进行设置?

Flink CDC里使用同步mysql数据时 无法指定需要的时区,只能按数据库本身的时区进行设置? 多个实例时区不一致集成到一起的时候咋办 ? flinkcdc3.0换成utc就报错,Caused by: org.apache.flink.table.api.ValidationException: The MySQL server has a timezone offset (28800 s.....

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

我用flink同步2张mysql表到es, 但是调试的数据和数据库里的实际数据不一样是为啥?

我用flink同步2张mysql表到es, 但是调试的数据和数据库里的实际数据不一样是为啥?

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

Flink CDC 里我现在需要同步一个数据库的数据转换到另一个库需要怎么做?

Flink CDC 里我现在需要同步一个数据库的数据转换到另一个库,大概有100+张表数据,有些数据需要清洗。又不能影响业务正常使用。我想着用CDC程序同步,但是可能要同时起很多source job,这样对原数据库的会有什么影响吗?

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

flink pg cdc 在同步数据库的时候一直会报检查点失败,我看了哈每次都是同样的两个数据库。

我想问一下,pg cdc 在执行检查点的时候是不是要和数据库有关系,比如提交slot 的消费点,我手动改了一下这两个数据库中监控的表,检查点马上就成功了,还有就是检查点执行频繁了对数据库性能有影响没得,如果这个库长时间没有变动,会导致检查点失败,有什么解决办法没得(目前我想到就是定时更新一个表中的某条数据)。 下面是我改了数据后的检查点,基本上都是成功。

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

flink cdc 3.0 整库同步数据,会导致业务数据库正常访问吗?比如被锁定,或者负载变高。

我现在使用的是flink cdc pipeline的方式,整库从mysql同步到StarRocks里面,首次全量是否会对mysql造成大量资源消耗,导致影响业务服务。

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

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

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

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

使用Flink同步MySQL到doris数据库中,时间格式异常

当我完成同步时,我发现Doris数据库中的所有时间格式都变为了如此:1970-02-01 11:00:00.000000,在所有时间格式后面追加了一个点和6个零,这是怎样造成的,该如何解决这个问题

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

产品推荐

阿里云实时计算Flink

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

+关注