logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

Flinkcdc postgres排查改源码Caused by: org.postgresql.util.PSQLException: This connection has been closed.

2025-08-05 18:14:44org.apache.flink.util.FlinkException: Global failure triggered by OperatorCoordinator for 'Source: PostgresParallelSource -> amos.time_captured-amos.billed_items-amos.pickslip_detai

#maven#大数据#hbase +4
部分字段CDC

Flink CDC PostgreSQL连接器在执行快照读取任务时出现异常,错误发生在PostgresScanFetchTask类的第313行。该错误表明在创建表数据事件时出现问题,可能导致Postgres数据库快照分割读取失败。具体错误信息显示为"org.apache.flink.cdc.connectors.postgres.source.fetch.PostgresScanFetc

文章图片
#java
到底了