我用 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
根据你提供的信息,这个错误通常是由于 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 版本配合使用。然而,该错误指出连接协议版本不受支持。
要解决这个问题,建议你检查以下几点:
确认版本兼容性:确保 Flink SQL Connectors 的版本与 OceanBase 的版本兼容。请查阅文档、官方发布说明或与 Flink 社区和 OceanBase 团队取得联系以获取更详细的版本兼容性信息。
更新 Connectors 版本:尝试更新 Flink SQL Connectors 的版本以适应所使用的 OceanBase 版本。可能需要使用相应版本的 Connectors 或者等待具有兼容性修复的新版本发布。
检查配置和依赖项:确保 Flink 的配置正确,并且所使用的所有依赖项(如 oblogproxy)与版本兼容并正确安装。还可以尝试重新安装和配置相关组件以解决潜在的配置问题。
根据常见的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
通常是由于 OceanBase 数据库的客户端版本与 Flink CDC 连接器所使用的协议版本不兼容导致的。
这个 oblogproxy 包是交付那边提供的吗,看这个报错应该是使用的版本不对。此回答整理至钉群“Flink CDC 社区”。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。