Hello,
I am running streaming flink job and I was using cancel command with savepoint
to cancel the job. From flink 1.10 version stop command should be used instead
of cancel command.
But I am getting below error sometimes. Please let me know what might be the
issue.
{"host":"cancel1-flinkcli-jobsubmission-55tgq","level":"info","log":{"message":"The
flink command to be executed is /opt/flink/bin/flink stop -p
/opt/flink/share/cflkt-flink/external_pvc -d ec416bf906915e570ef53b242d3d0bb0
"},"time":"2020-09-02T12:32:19.979Z","type":"log"}
{"host":"cancel1-flinkcli-jobsubmission-55tgq","level":"info","log":{"message":"=====
Submitting the Flink job "},"time":"2020-09-02T12:32:19.983Z","type":"log"}
WARNING: An illegal reflective access operation has occurred
WARNING: Illegal reflective access by
org.apache.hadoop.security.authentication.util.KerberosUtil
(file:/opt/flink/lib/flink-shaded-hadoop-2-uber-2.6.5-7.0.jar) to method
sun.security.krb5.Config.getInstance()
WARNING: Please consider reporting this to the maintainers of
org.apache.hadoop.security.authentication.util.KerberosUtil
WARNING: Use --illegal-access=warn to enable warnings of further illegal
reflective access operations
WARNING: All illegal access operations will be denied in a future release
------------------------------------------------------------
The program finished with the following exception:
org.apache.flink.util.FlinkException: Could not stop with a savepoint job
"ec416bf906915e570ef53b242d3d0bb0".
at
org.apache.flink.client.cli.CliFrontend.lambda$stop$5(CliFrontend.java:458)
at
org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:841)
at org.apache.flink.client.cli.CliFrontend.stop(CliFrontend.java:450)
at
org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:905)
at
org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:966)
at java.base/java.security.AccessController.doPrivileged(Native Method)
at java.base/javax.security.auth.Subject.doAs(Subject.java:423)
at
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1692)
at
org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:966)
Caused by: java.util.concurrent.TimeoutException
at
java.base/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1886)
at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2021)
at
org.apache.flink.client.cli.CliFrontend.lambda$stop$5(CliFrontend.java:456)
... 9 more
Thanks,
Suchithra
