刚下的Flink 1.17.1 - -是我环境问题?

刚下的Flink 1.17.1 - -是我环境问题?2b5ad6c954d9b660f35d2fab2a3b231e.png

展开
收起
真的很搞笑 2023-08-09 13:19:24 203 分享 版权
1 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    这个错误提示主要有以下几点:

    Flink与Hadoop核心Jar包版本不兼容,导致Hadoop安全类的反射调用报错。

    Apache Commons Cli库版本过低,找不到 Option类的hasOption方法。

    这说明您Flink环境下依赖的一些第三方Jar存在兼容性问题。

    几点解决方案:

    检查Flink所需Hadoop版本,与本地Hadoop环境版本保持一致。

    升级Apache Commons Cli到Flink兼容版本,比如升级到1.4或以上版本。

    使用自带依赖运行,在启动时增加--shade或者--dependencies参数。

    在提交环境中排除冲突Jar包。

    运行上面提示的--illegal-access参数,转成警告继续运行。

    如果非必须,可以尝试升级Flink版本到最新动态避免这个问题。

    2023-08-10 17:21:28
    赞同 展开评论

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

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