Flink CDC中pg cdc 有遇到这个吗？

原因可能是:

PostgreSQL事务正在超时
如果PostgreSQL具有长时间运行的事务,可能会占用较长时间的锁,导致pg_cdc获取更改的语句被取消。

PostgreSQL资源紧张
如果PostgreSQL服务器负载高,资源紧张,可能会导致事务及查询响应时间变长,超出pg_cdc的 lock_timeout设置。

PostgreSQL二进制日志滞后
如果PostgreSQL二进制日志较滞后,pg_cdc同步更改事件时也可能会超时。

权限问题
pg_cdc连接PostgreSQL数据源时,需要具有REPLICATION权限。如果权限不足,也可能导致类似的错误。

以上是最有可能导致上述pg cdc日志的原因,可以从这几方面着手解决:

优化PostgreSQL事务
提升PostgreSQL服务器配置
增大pg_cdc lock_timeout设置
确认pg_cdc用户具有足够的REPLICATION权限

日志有ERROR信息 库有锁表导致执行超时，此回答整理自钉群“Flink CDC 社区”