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

Flink CDC这个读取pg为啥会有这个错 是flink版本问题嘛 ?

Flink CDC这个读取pg为啥会有这个错 是flink版本问题嘛 这里用的1.16.2的 但是1.13.5的就可以?image.png

展开
收起
真的很搞笑 2023-11-16 08:16:31 83 0
3 条回答
写回答
取消 提交回答
  • 从你提供的错误信息来看,这个问题可能是由于Flink的PG connector版本和你的PostgreSQL版本不匹配导致的。Flink的PG connector默认使用的是PostgreSQL的JDBC驱动,而这个驱动并不支持所有版本的PostgreSQL。

    具体来说,你使用的Flink版本对应的PG connector可能使用了PostgreSQL的JDBC驱动9.4版本,而这个版本并不支持你的PostgreSQL版本所特有的某些特性。因此,当你尝试使用这些特性时,就会遇到错误。

    解决这个问题的一个方法是将Flink的PG connector升级到最新的版本,或者降级你的PostgreSQL版本到一个更老的版本,使得它们能够兼容。

    另外,你也可以尝试使用PostgreSQL的官方Connector,而不是Flink的PG connector。PostgreSQL的官方Connector通常会随着PostgreSQL版本的更新而更新,因此它应该可以支持所有版本的PostgreSQL。

    2023-11-16 09:07:44
    赞同 展开评论 打赏
  • 北京阿里云ACE会长

    在Flink 1.13.5版本中,CDC支持PostgreSQL数据库,而在Flink 1.16.2版本中,CDC不再支持PostgreSQL数据库,而是新增了对MySQL和Oracle数据库的支持。因此,如果使用Flink 1.16.2版本来读取PostgreSQL数据库,就会出现这个错误。
    要解决这个问题,可以尝试以下两种方法:

    1. 降级Flink版本:将Flink版本降级到1.13.5,以便使用CDC对PostgreSQL的支持。
    2. 升级PostgreSQL数据库:如果无法降级Flink版本,可以考虑升级PostgreSQL数据库到最新版本,以查看是否能够与Flink 1.16.2兼容。
      另外,如果在使用Flink CDC时遇到任何问题,可以尝试
    2023-11-16 08:43:26
    赞同 展开评论 打赏

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

相关产品

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

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