tongchenkeji 发表于:2023-10-30 19:19:470次点击 已关注取消关注 关注 私信 Flink有没有用过人大金仓做来源库的 现在job部署上去虽然不报错 但是什么数据都读不到 ?[阿里云实时计算 Flink版] 暂停朗读为您朗读 Flink有没有用过人大金仓做来源库的 现在job部署上去虽然不报错 但是什么数据都读不到 用的pg的cdc ? 「点点赞赏,手留余香」 赞赏 还没有人赞赏,快来当第一个赞赏的人吧! 海报 实时计算Flink版# 关系型数据库2577# 实时计算 Flink版3179# 流计算2236
小周sirAM 2023-11-27 18:36:16 1 我了解到,在 Flink CDC 中,pg_cdc 插件主要用于连接 PostgreSQL 数据库。然而,由于人大金仓并非基于 PostgreSQL 开发的关系型数据库管理系统,而是基于 Ingres 开发的关系型数据库管理系统,因此 Flink CDC 暂时不支持直接连接人大金仓作为数据源。不过,如果你想将人大金仓作为 Flink CDC 的数据源,也并不是完全不可能。你可以考虑通过某种方式将人大金仓中的数据复制到一个支持 pg_cdc 插件的数据库中(例如 PostgreSQL),然后使用 Flink CDC 连接这个数据库来读取数据。这种方式需要额外的工作量和技术投入,但是在某些情况下也是可行的。
sun20AM 2023-11-27 18:36:16 2 Flink可以连接到各种数据库,包括人大金仓和PostgreSQL。如果你的Flink job无法从人大金仓数据库读取数据,可能有以下几个原因: 连接问题:确保你的Flink job能够正确连接到人大金仓数据库。检查你的连接URL、用户名和密码是否正确。 权限问题:确保你的Flink job有足够的权限从人大金仓数据库读取数据。检查你的用户是否有读取数据的权限。 数据问题:确保你的数据在人大金仓数据库中。检查你的表是否存在,你的数据是否正确。 CDC问题:如果你的Flink job使用了CDC(Change Data Capture),确保你的CDC配置正确。检查你的CDC源、你的CDC路径和你的CDC选项是否正确。 Flink问题:如果以上都没有问题,那可能是Flink的问题。你可以检查你的Flink配置,或者检查你的Flink版本。 总的来说,解决这个问题需要你从多个角度进行考虑,包括你的连接、你的权限、你的数据和你的CDC。你可以先检查你的连接和权限,然后再检查你的数据和CDC,最后再检查你的Flink。
我了解到,在 Flink CDC 中,pg_cdc 插件主要用于连接 PostgreSQL 数据库。然而,由于人大金仓并非基于 PostgreSQL 开发的关系型数据库管理系统,而是基于 Ingres 开发的关系型数据库管理系统,因此 Flink CDC 暂时不支持直接连接人大金仓作为数据源。
不过,如果你想将人大金仓作为 Flink CDC 的数据源,也并不是完全不可能。你可以考虑通过某种方式将人大金仓中的数据复制到一个支持 pg_cdc 插件的数据库中(例如 PostgreSQL),然后使用 Flink CDC 连接这个数据库来读取数据。这种方式需要额外的工作量和技术投入,但是在某些情况下也是可行的。
Flink可以连接到各种数据库,包括人大金仓和PostgreSQL。如果你的Flink job无法从人大金仓数据库读取数据,可能有以下几个原因:
连接问题:确保你的Flink job能够正确连接到人大金仓数据库。检查你的连接URL、用户名和密码是否正确。
权限问题:确保你的Flink job有足够的权限从人大金仓数据库读取数据。检查你的用户是否有读取数据的权限。
数据问题:确保你的数据在人大金仓数据库中。检查你的表是否存在,你的数据是否正确。
CDC问题:如果你的Flink job使用了CDC(Change Data Capture),确保你的CDC配置正确。检查你的CDC源、你的CDC路径和你的CDC选项是否正确。
Flink问题:如果以上都没有问题,那可能是Flink的问题。你可以检查你的Flink配置,或者检查你的Flink版本。
总的来说,解决这个问题需要你从多个角度进行考虑,包括你的连接、你的权限、你的数据和你的CDC。你可以先检查你的连接和权限,然后再检查你的数据和CDC,最后再检查你的Flink。