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

我用 flinksql 做cdc,报这个错。什么原因?

我用 flinksql 做cdc,报这个错。
异常:
ERROR com.oceanbase.clogproxy.client.connection.ClientHandler - Unsupported protocol version: 18944
flink版本:flink-1.17.0
连接包:
flink-sql-connector-oceanbase-cdc-2.4.0.jar
oceanbase-client-2.4.2.jar

OceanBase 企业版 3.2.3.2
模式 oracle
oblogproxy-2.2.3
我安装了 oblogproxy-2.2.3,还是报 ERROR com.oceanbase.clogproxy.client.connection.ClientHandler - Unsupported protocol version: 18944

展开
收起
小易01 2023-07-26 08:24:22 84 0
4 条回答
写回答
取消 提交回答
  • 根据你提供的信息,这个错误通常是由于 Flink SQL Connectors 版本与 OceanBase 的版本不兼容引起的。

    在你的情况中,使用 Flink 1.17.0 版本,flink-sql-connector-oceanbase-cdc-2.4.0.jar 和 oceanbase-client-2.4.2.jar 连接包,与 OceanBase 企业版 3.2.3.2 版本配合使用。然而,该错误指出连接协议版本不受支持。

    要解决这个问题,建议你检查以下几点:

    1. 确认版本兼容性:确保 Flink SQL Connectors 的版本与 OceanBase 的版本兼容。请查阅文档、官方发布说明或与 Flink 社区和 OceanBase 团队取得联系以获取更详细的版本兼容性信息。

    2. 更新 Connectors 版本:尝试更新 Flink SQL Connectors 的版本以适应所使用的 OceanBase 版本。可能需要使用相应版本的 Connectors 或者等待具有兼容性修复的新版本发布。

    3. 检查配置和依赖项:确保 Flink 的配置正确,并且所使用的所有依赖项(如 oblogproxy)与版本兼容并正确安装。还可以尝试重新安装和配置相关组件以解决潜在的配置问题。

    2023-07-31 22:36:25
    赞同 展开评论 打赏
  • 北京阿里云ACE会长

    根据常见的Flink SQL CDC错误,可能的原因是以下之一:
    数据库连接错误。请确保您的数据库连接字符串、用户名和密码正确,并且数据库可以正常访问。您可以尝试使用命令行工具或其他客户端工具来测试数据库连接是否正常。
    表不存在或表结构发生了变化。请确保您的表存在,并且表的结构与Flink SQL CDC的配置一致。如果表结构发生了变化,例如添加或删除了列,需要重新配置Flink SQL CDC的表模式(schema)。
    CDC源配置错误。请确保您的CDC源配置正确,并且可以正常捕获变化数据。您可以尝试使用Debezium命令行工具(如bin/kafka-console-consumer.sh)检查CDC源是否可以正常发送变化数据。
    Flink SQL语句错误。请确保您的Flink SQL语句正确,并且可以正常执行。您可以尝试使用Flink SQL客户端工具(如bin/sql-client.sh)来测试F

    2023-07-29 16:10:39
    赞同 展开评论 打赏
  • 存在即是合理

    通常是由于 OceanBase 数据库的客户端版本与 Flink CDC 连接器所使用的协议版本不兼容导致的。

    2023-07-27 16:13:16
    赞同 展开评论 打赏
  • 意中人就是我呀!

    这个 oblogproxy 包是交付那边提供的吗,看这个报错应该是使用的版本不对。此回答整理至钉群“Flink CDC 社区”。

    2023-07-26 12:16:50
    赞同 展开评论 打赏

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

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载