Flink有没有用过人大金仓做来源库的 现在job部署上去虽然不报错 但是什么数据都读不到 ?[阿里云实时计算 Flink版]

Flink有没有用过人大金仓做来源库的 现在job部署上去虽然不报错 但是什么数据都读不到 用的pg的cdc ?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. 我了解到,在 Flink CDC 中,pg_cdc 插件主要用于连接 PostgreSQL 数据库。然而,由于人大金仓并非基于 PostgreSQL 开发的关系型数据库管理系统,而是基于 Ingres 开发的关系型数据库管理系统,因此 Flink CDC 暂时不支持直接连接人大金仓作为数据源。
    不过,如果你想将人大金仓作为 Flink CDC 的数据源,也并不是完全不可能。你可以考虑通过某种方式将人大金仓中的数据复制到一个支持 pg_cdc 插件的数据库中(例如 PostgreSQL),然后使用 Flink CDC 连接这个数据库来读取数据。这种方式需要额外的工作量和技术投入,但是在某些情况下也是可行的。

  2. Flink可以连接到各种数据库,包括人大金仓和PostgreSQL。如果你的Flink job无法从人大金仓数据库读取数据,可能有以下几个原因:

    1. 连接问题:确保你的Flink job能够正确连接到人大金仓数据库。检查你的连接URL、用户名和密码是否正确。

    2. 权限问题:确保你的Flink job有足够的权限从人大金仓数据库读取数据。检查你的用户是否有读取数据的权限。

    3. 数据问题:确保你的数据在人大金仓数据库中。检查你的表是否存在,你的数据是否正确。

    4. CDC问题:如果你的Flink job使用了CDC(Change Data Capture),确保你的CDC配置正确。检查你的CDC源、你的CDC路径和你的CDC选项是否正确。

    5. Flink问题:如果以上都没有问题,那可能是Flink的问题。你可以检查你的Flink配置,或者检查你的Flink版本。

    总的来说,解决这个问题需要你从多个角度进行考虑,包括你的连接、你的权限、你的数据和你的CDC。你可以先检查你的连接和权限,然后再检查你的数据和CDC,最后再检查你的Flink。