Flink中是什么问题?

Flink中是什么问题?java.lang.nosuchmethoderror: org.apache.commons.cli.CommandLine.hasOption(Lorg/apache/commons/cli/Option;)Z at org.apache.flink.client.cli.CliFrontendParser.createSavepointRestoreSettings(CliFrontendParser.java:631) at org.apache.flink.client.cli.ProgramOptions.(ProgramOptions.java:119) at org.apache.flink.client.cli.ProgramOptions.create(ProgramOptions.java:192) at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:230) at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1085) at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1163) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:422) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1556) at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1163)

展开
收起
真的很搞笑 2023-05-16 17:25:14 290 分享 版权
2 条回答
写回答
取消 提交回答
  • 存在即是合理

    这个错误通常是由于Flink版本不兼容或命令行参数设置不正确导致的。具体来说,它表示在执行flink savepoint restore命令时,Flink客户端cli无法找到hasOption方法,导致出错。

    解决这个问题的方法包括:

    1. 确认Flink版本是否与命令行参数中指定的版本一致。
    2. 检查命令行参数是否正确设置,特别是确保没有重复的选项或错误的选项。
    3. 如果使用了较旧的Flink版本,则可以尝试升级到最新版本以解决问题。
    2023-05-18 13:03:11
    赞同 展开评论
  • 应该是依赖冲突,你的程序里打了个低版本的common cli,此回答整理自钉群“【③群】Apache Flink China社区”

    2023-05-16 17:35:31
    赞同 展开评论

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

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