Flink有没有用过人大金仓做来源库的 现在job部署上去虽然不报错 但是什么数据都读不到 用的pg的cdc ?
我了解到,在 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。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。