flink1.17.0 读取 SLS 报错是对应的版本冲突么?java.lang.NoClassDefFoundError: org/apache/flink/api/java/typeutils/ResultTypeQueryable,
出现java.lang.NoClassDefFoundError: org/apache/flink/api/java/typeutils/ResultTypeQueryable
这一特定错误与SLS连接器版本冲突的明确关系。然而,该错误通常表明在运行环境中缺失了某个类定义,这可能是因为依赖不完整或版本不兼容所致。
为了解决这个问题,您可以尝试以下几个步骤:
检查依赖: 确保您的项目依赖中包含了所有必要的Flink库,特别是那些与类型系统相关的部分。根据Flink的版本更新,某些类可能已被移动或重构,因此需要确保使用的Flink版本与连接器版本之间兼容。对于SLS连接器,虽然具体版本号未直接给出,但建议访问Maven Central (https://search.maven.org) 或 Sonatype Snapshot Repository (https://oss.sonatype.org) 搜索与Flink 1.17.0兼容的SLS连接器版本
清理和更新依赖: 清理本地Maven或Gradle缓存,然后重新构建项目,确保所有依赖都是最新且匹配的。
查看连接器文档: 根据文档指引,直接查看SLS连接器的官方文档或示例代码,确认所需的依赖项和版本信息。文档中提到的DataStream连接器包括SLS在内的多个示例,可以作为参考来校验您的依赖配置
版本一致性: 确保您的Flink核心库版本与SLS连接器版本以及其他第三方库版本之间保持良好的兼容性。如果使用了特定版本的Flink,应当查找对应适配该版本的连接器版本。
合并META-INF: 如果项目中使用了多个Connector,确保在pom.xml中配置了正确的策略来合并META-INF目录,避免类路径冲突
相关链接 https://help.aliyun.com/zh/flink/user-guide/develop-a-jar-draft
idea把provided dependency include 勾选上 此回答整理自钉群“实时计算Flink产品公有云外部客户交流群”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。