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

在Flink CDC中,想问cdc 同步,源端数据库编码gbk ,得到增量值乱码这个问题怎么解决啊?

在Flink CDC中,想问下cdc 同步,如果源端数据库编码gbk ,得到的增量值为乱码这个问题怎么解决啊?

阿里云文档 2024-07-26

基于Flink平台同步MySQL数据至StarRocks

CTAS可以实现单表的结构和数据同步,CDAS可以实现整库同步或者同一库中的多表结构和数据同步。本文为您介绍如何使用实时计算Flink平台和E-MapReduce StarRocks通过CTAS&CDAS功能实现实时数仓中TP(Transaction Processing)和AP(Analytical Processing)数据同步的场景。

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

Flink CDC没有同步 这个表,数据库,帮忙看看啥原因?

Flink CDC没有同步VT53PRQ3Z1J7RUAXEURB4G59KLS 这个表,数据库,视图都没有这个,帮忙看看啥原因?

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

在Flink CDC中同步mysql数据时候相比MIXED 是不是产生更多日志,会对数据库有影响吗?

在Flink CDC中同步mysql数据时候 binlog_format=ROW,这个相比MIXED 是不是产生更多日志,会对数据库有影响吗?

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

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

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

问答 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-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造成大量资源消耗,导致影响业务服务。

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

产品推荐

阿里云实时计算Flink

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

+关注