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

给pgsql集群做flink cdc的 用从节点ip连接 刚开始正常,十几分钟报错 怎么回事?

给pgsql集群做flink cdc的 用从节点ip连接 刚开始正常,十几分钟或者一个小时后 报这样的错 怎么回事?

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

FlinkCDC2.4版本读pgsql的增量,如何在Flink的程度停止时自动释放掉pg的slot?

FlinkCDC2.4版本去读pgsql的增量,如何在Flink的程度停止时自动释放掉pg的slot,我这边查看flink已经关掉了,但是SELECT * FROM pg_replication_slots where active='false' and slot_type='logical';还能查到是什么情况?

问答 2022-11-23 来自:开发者社区

请问下各位大佬pgsql同步的时候如果有字段为空Flink这边会报下面这种错,该怎么处理呢: \t

请问下各位大佬pgsql同步的时候如果有字段为空Flink这边会报下面这种错,该怎么处理呢: \t\N\t0\t0\t0\t0\nError: Value count does not match column count. Expect 12, but got 7.

问答 2022-07-11 来自:开发者社区

pgsql -> flink cdc -> flink -> mysql,如果一张pgsql cdc

pgsql -> flink cdc -> flink -> mysql,如果一张pgsql cdc表写入两张mysql表(不同库),会报 please make sure to use a distinct replication slot name for each;有一个source写入两个sink的解决方案吗(flink sql)?

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

产品推荐

阿里云实时计算Flink

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

+关注