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

Flink这个catalog里边不支持oracle吗?

Flink这个catalog里边不支持oracle吗?
1bd42a40a2758e1f03bacfb33ffae533.png

展开
收起
嘟嘟嘟嘟嘟嘟 2024-01-17 08:39:58 107 0
3 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    Flink的Catalog确实支持多种数据源,包括Oracle。通过使用Flink的Oracle catalog,用户能够从Flink SQL查询中访问所有已经在Oracle中创建的表。需要注意的是,Oracle catalog只允许用户创建或访问现有的Oracle表,对于使用其他数据源的表,则需要在其他的catalog中定义,比如in-memory catalog或者Hive catalog。

    自Flink 1.15版本以后,官方提供了oracle版的Table的DDL定义,但并未提供catalog的DDL定义。为了满足大数据中间件的需求,可以参考官方PostgreSQL的catalog源代码,扩展JdbcCatalog以实现oracle的catalog。

    此外,值得一提的是,从Flink CDC 2.1版本开始,已经增加了对Oracle的支持。该版本的发布进一步拓宽了Flink对不同数据源的处理能力。

    2024-01-17 14:14:18
    赞同 展开评论 打赏
  • 十分耕耘,一定会有一分收获!

    楼主你好,据我所知阿里云Flink的Catalog模块默认情况下不直接支持Oracle数据库,但可以通过使用外部库或者自定义Catalog来实现与Oracle数据库的集成。

    一种方式是使用外部库,例如Apache Hudi或者Apache Calcite,将Oracle数据库集成到Flink中。

    另一种方式是自定义Catalog。

    但是需要注意的是,通过外部库或者自定义Catalog集成Oracle数据库可能需要额外的配置和定制开发。

    2024-01-17 08:45:58
    赞同 展开评论 打赏
  • Flink在较早的版本中并未提供对Oracle的直接支持,然而在2021年11月15日发布的Flink CDC 2.1版本中,官方通过引入内置Debezium组件,增加了对Oracle数据库的支持。因此,您可以通过使用这个版本的Flink并配合Debezium组件连接到Oracle数据库。

    需要注意的是,连接Oracle 19c可能会遇到ORA-44609错误,这可能是因为Oracle 19c不再支持使用LogMiner进行数据捕获。此外,对于Oracle 11g,Flink也并未提供支持。

    2024-01-17 08:45:54
    赞同 展开评论 打赏

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

相关产品

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

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

    相关镜像