Hi community: I'm working on a flink cluster on YARN application mode,which is authenticated by Kuberos. It works well on flink run and flink list command as follows :
./bin/flink run-application -t yarn-application > ./examples/streaming/TopSpeedWindowing.jar > ./bin/flink list -t yarn-application -Dyarn.application.id > =application_XXXX_YY I hide authentication params on the preceding run case. But there are some unsatisfactory problems that happen while running flink cancel (cause I want savepoint and smooth upgrade etc.) flink cancel -t yarn-application -Dyarn.application.id=application_XXXX_YY > <jobid> Preceding jobid comes from flink list .Exception stack as follows: java .lang .NoSuchMethodError: > org.apache.commons.cli.CommandLine.hasOption(Long/apach/commons/cli/Option;)Z > at org.apach.flink.client.cli.CancelOptions.<init>(CancelOptions.java:47) > at org.apach.flink.client.cli.CliFrontend.parseAndRun( > CliFrontend.java:1107) > at org.apach.flink.client.cli.CliFrontend.lambda&mainInternal$9( > CliFrontend.java:1189) > at java.security.AccessController.doPrivileged(Native Method) > at javax.security.auth.Subject.doAs(Subject.java:422) > at > org.apache.hadoop.security.UaerGroupInformation.doAs(UaerGroupInformation.java:41) > at org.apach.flink.client.cli.CliFrontend.mainInternal( > CliFrontend.java:1189) > at org.apach.flink.client.cli.CliFrontend.main( CliFrontend.java:1157) at org.apach.flink.client.cli.CliFrontend.cancel( CliFrontend.java:613) > I guess I missed some authority params? Additionally flink version is 1.17.1 Thank you Regards, Teii
