今天在进行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 集群不需要重启,直接就起作用了。

Logo

Agent 垂直技术社区,欢迎活跃、内容共建。

更多推荐