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

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

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

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

    我了解到,在 Flink CDC 中,pg_cdc 插件主要用于连接 PostgreSQL 数据库。然而,由于人大金仓并非基于 PostgreSQL 开发的关系型数据库管理系统,而是基于 Ingres 开发的关系型数据库管理系统,因此 Flink CDC 暂时不支持直接连接人大金仓作为数据源。
    不过,如果你想将人大金仓作为 Flink CDC 的数据源,也并不是完全不可能。你可以考虑通过某种方式将人大金仓中的数据复制到一个支持 pg_cdc 插件的数据库中(例如 PostgreSQL),然后使用 Flink CDC 连接这个数据库来读取数据。这种方式需要额外的工作量和技术投入,但是在某些情况下也是可行的。

    2023-10-31 14:51:50
    赞同 展开评论 打赏
  • 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。

    2023-10-31 14:43:10
    赞同 展开评论 打赏

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

相关产品

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

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