开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

我flink启动以后已经连上pg数据库了,大家有经验知道这是什么问题吗?

我flink启动以后已经连上pg数据库了,pg数据库修改数据后通过 SELECT slot_name, confirmed_flush_lsn FROM pg_replication_slots;查看 插槽是活跃的,而且有随着数据修改lsn有偏移量,但是我的source没有响应,没有数据进入source,大家有经验知道这是什么问题吗? (之前都好好的,昨天启动的时候发现监听不到数据了,期间数据库配置和flink作业都没有发生过改变)0ec8943e086ca0ec480ce2c912dd6b00.png

展开
收起
真的很搞笑 2024-02-24 12:39:37 47 0
1 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    可能的原因有以下几点:

    1. Flink作业的Source没有正确配置,导致无法从PostgreSQL数据库中读取数据。请检查Flink作业的Source配置是否正确,包括连接信息、查询语句等。

    2. PostgreSQL数据库的replication slot没有正确设置。请确保在PostgreSQL数据库中创建了正确的replication slot,并且允许外部连接。

    3. Flink作业的并行度设置不合适。如果Flink作业的并行度设置得过高,可能会导致Source无法及时处理数据。可以尝试调整Flink作业的并行度设置,观察是否能解决问题。

    4. 网络问题。请检查Flink作业所在的服务器与PostgreSQL数据库之间的网络连接是否正常。

    5. Flink作业的日志中可能会有更详细的错误信息,建议查看Flink作业的日志以获取更多线索。

    2024-02-24 16:41:03
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载