我flink启动以后已经连上pg数据库了,pg数据库修改数据后通过 SELECT slot_name, confirmed_flush_lsn FROM pg_replication_slots;查看 插槽是活跃的,而且有随着数据修改lsn有偏移量,但是我的source没有响应,没有数据进入source,大家有经验知道这是什么问题吗? (之前都好好的,昨天启动的时候发现监听不到数据了,期间数据库配置和flink作业都没有发生过改变)
可能的原因有以下几点:
Flink作业的Source没有正确配置,导致无法从PostgreSQL数据库中读取数据。请检查Flink作业的Source配置是否正确,包括连接信息、查询语句等。
PostgreSQL数据库的replication slot没有正确设置。请确保在PostgreSQL数据库中创建了正确的replication slot,并且允许外部连接。
Flink作业的并行度设置不合适。如果Flink作业的并行度设置得过高,可能会导致Source无法及时处理数据。可以尝试调整Flink作业的并行度设置,观察是否能解决问题。
网络问题。请检查Flink作业所在的服务器与PostgreSQL数据库之间的网络连接是否正常。
Flink作业的日志中可能会有更详细的错误信息,建议查看Flink作业的日志以获取更多线索。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。