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

实时计算 Flink版产品使用合集之pg是主备的话,支持连接pg备库吗

问题一:Flink CDC流处理的过程中,某一条数据的异常,大家一般怎么处理的,使整个流断掉不合适吧? Flink CDC流处理的过程中,某一条数据的异常,大家一般怎么处理的,使整个流断掉不合适吧? 参考回答: 在Flink CDC流处理过程中,如果某一条数据出现异常,中断整个流是不合适的。通常情况下,您可以采取以下方法来处理异常数据,并保持流的连续性...

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

Flink CDC里从pg库采集cdc数据,flink程序断了之后,为啥不能指定从断的地方重新消费?

Flink CDC里从pg库采集cdc数据,flink程序。断了之后,为啥不能指定从断的地方重新消费changelog数据呢,现在代码里只支持initial和latest,其它模式不支持怎么办?

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

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

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

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

现在Flink CDC-3.0.1支持从PG(16.x)的备库复制嘛?

现在Flink CDC-3.0.1支持从PG(16.x)的备库复制嘛?

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

实时计算 Flink版有没有试过pg 数据同步,我现在开启了同步主库很卡?

实时计算 Flink版有没有试过pg 数据同步,我现在开启了同步主库很卡?你们是怎么配置的

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

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

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

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

Flink CDC里我PG库的字段类型就出现上面的警告,如果timestamp(3)就可以什么问题?

Flink CDC里我PG库的字段类型就出现上面的警告,如果timestamp(3)就可以。返回的数据:确实没有 create_time字段给过滤了,请问这是什么问题?我用的是flink-sql-connector-postgres-cdc-2.4.1.jar

问答 2023-12-04 来自:开发者社区

Flink CDC中pg本身是不支持吧,但是如果是单机的话,我想知道从库能不能也实现呢?

Flink CDC中pg本身是不支持吧,但是如果是单机的话,利用decoderbufs插件还是能实现,就是我想知道从库能不能也实现呢?

问答 2023-09-07 来自:开发者社区

Flink CDC在pg从库同步数据时候报错?

Flink CDC在pg从库同步数据时候报错?

问答 2023-08-22 来自:开发者社区

Flink CDC sqlserver-cdc同步1000W左右数据量到pg库,sqlserver?

Flink CDC sqlserver-cdc同步1000W左右数据量到pg库,sqlserver日志文件设置的初始10G、最大200G,日志利用率45~80%左右,每次只能同步200~500W左右的数据量到pg,就一直是阻塞等待状态了,只有手工反复重启sqlserver反向代理,数据才能完整的推到下游pg库,sqlserver日志等待模式状态为REPLICATION, 请问这种情况是啥原因导致....

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

产品推荐

阿里云实时计算Flink

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

+关注