FLINK 1.13 版本出现这个是什么问题啊?和版本有关吗,配置都是对的?

FLINK 1.13 版本出现这个是什么问题啊?和版本有关吗,配置都是对的?image.png

展开
收起
真的很搞笑 2023-09-20 07:46:38 76 分享 版权
1 条回答
写回答
取消 提交回答
  • Flink 1.13 版本出现 java.lang.NoClassDefFoundError: org/apache/flink/api/common/typeinfo/TypeInformation$BasicTypeInfo 错误,可能是由于引入了 flink-connector-elasticsearch 依赖导致的。

    flink-connector-elasticsearch 在 1.13 版本中已经迁移到了新的依赖 flink-statebackend-rocksdb,因此需要将 flink-connector-elasticsearch 依赖的版本升级到 1.13.1 以上。

    如果仍然无法解决这个问题,可以尝试在 Stack Overflow 上提问,或者向 Flink 社区寻求帮助。

    2023-10-19 09:50:52
    赞同 展开评论

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

还有其他疑问?
咨询AI助理