Hello,
I am running a flink job which I stop it with a savepoint:

./bin/flink stop --savepointPath /tmp/flink-savepoints
0b3b584a298afa372491eff5e3d2160b
Suspending job "0b3b584a298afa372491eff5e3d2160b" with a CANONICAL
savepoint.


However this is what I get in the cli
------------------------------------------------------------
The program finished with the following exception:

org.apache.flink.util.FlinkException: Could not stop with a savepoint job
"0b3b584a298afa372491eff5e3d2160b".
at
org.apache.flink.client.cli.CliFrontend.lambda$stop$4(CliFrontend.java:595)
at
org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:1041)
at org.apache.flink.client.cli.CliFrontend.stop(CliFrontend.java:578)
at
org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1110)
at
org.apache.flink.client.cli.CliFrontend.lambda$mainInternal$9(CliFrontend.java:1189)
at
org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
at
org.apache.flink.client.cli.CliFrontend.mainInternal(CliFrontend.java:1189)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1157)
Caused by: java.util.concurrent.TimeoutException
at
java.base/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1950)
at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2085)
at
org.apache.flink.client.cli.CliFrontend.lambda$stop$4(CliFrontend.java:591)
... 7 more


What I also see is that actually a savepoint does get generated at the
specified path and my flink job is also stopped after a while.

Is there any setting which is making the cli program to timeout and is
there a way we can verify that the entire savepoint got generated on the
specified path ?

Thanks
Sachin

Reply via email to