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
Helm+github+dockerhub部署FlinkCDC Job

本文记录了Kubernetes资源配置修改的实验过程。通过调整资源配置后观察到内存限制成功变为1.5G,但发现任务意外重启的问题。实验结果表明,直接修改资源配置会导致任务重启,不符合预期。建议修改前应先执行savepoint操作保存状态,再实施重启,以避免数据丢失或中断。该发现对Kubernetes资源管理实践具有指导意义。

#flink
部分字段CDC

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

文章图片
#java
到底了