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

FLINK CDC 版本2.1.1对接oracle 11g出现debezium engine 关闭?

具体错误为: Caused by: java.lang.IllegalStateException: Retrieve schema history failed, the schema records for engine e87aa165-4234-40f0-bb5b-54cfd8b4825c has been removed, this might because the debezium engine has been shutdown due to other errors. 有大佬怎么解决的吗,急求在线解答。

展开
收起
八宝粥123 2023-05-19 09:35:38 481 0
1 条回答
写回答
取消 提交回答
  • 存在即是合理

    根据您提供的信息,问题可能是由于 Debezium 引擎关闭导致的。Debezium 是一个开源的分布式平台,用于将数据从各种源转换为 Apache Kafka。

    在 FLINK CDC 版本2.1.1 中,它可以与 Oracle 11g 数据库进行连接。但是,由于 Debezium 引擎关闭,可能会导致无法检索模式历史记录,从而导致连接失败。

    要解决此问题,您可以尝试以下步骤:

    1. 确保 Debezium 引擎正在运行。您可以通过检查 Debezium 控制台或日志来确认引擎是否正在运行。如果引擎未启动,请启动它并重试连接。

    2. 如果引擎已启动但仍然无法连接,请检查连接配置是否正确。确保您已经正确配置了连接参数,例如连接地址、端口、用户名和密码等。

    3. 如果连接配置正确但仍然无法连接,请检查 Oracle 数据库是否可用。您可以尝试使用其他工具(例如 SQL*Plus)连接到 Oracle 数据库并查看是否可以正常访问。

    4. 如果 Oracle 数据库可用但仍然无法连接,请检查 Debezium 配置文件是否正确。您可以检查 Debezium 配置文件中的连接参数是否正确,并尝试重新启动 Debezium 引擎以清除任何可能的问题。

    希望这些步骤可以帮助您解决问题。

    2023-05-19 18:25:06
    赞同 展开评论 打赏

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

相关产品

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

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

    相关镜像