Flinkji集群运行时出现以下错误:java.lang.NoSuchMethodError: org.apache.commons.cli.CommandLine.hasOption(Lorg/ap
·
今天在进行checkpoint的时候,编写代码没有问题,将代码上传至linux集群,然后运行flink任务没问题,但是带上checkpoint检查点运行就报如上问题
flink run -c com.bigdata.day06._01CheckPointDemo -s hdfs://bigdata01:9820/flink/checkpoint/bf416df7225b264fc34f8ff7e3746efe/chk-603 /opt/app/FlinkDemo-1.0-SNAPSHOT.jar
在进行手动savepoint的时候也报这个错误,比如:
flink savepoint 79f53c5c0bb3563b6b6ed3011176c411 hdfs://bigdata01:9820/flink-savepoint
为什么呢?
答案是:common-cli版本冲突
我使用的是flink1.17 ,本地和服务器都是,那我的解决方案如下:
将本地的 windows 上的 common-cli 拷贝到服务器上
将本地仓库的这个包:

上传至:

记得分发到集群服务器:
xsync.sh /opt/installs/flink/lib/commons-cli-1.5.0.jar
flink 集群不需要重启,直接就起作用了。
更多推荐
所有评论(0)