Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Invalid
-
1.17.0
-
None
-
None
Description
I've put together a simple demo app that reproduces the issue with instructions on how to reproduce:
https://github.com/kurtostfeld/flink-stop-issue
The issue is that with a very simple Flink DataStream API application, the `stop-with-savepoint` fails and times out like this:
./bin/flink stop --type native --savepointPath ../savepoints d69a952625497cca0665dfdcdb9f4718 Suspending job "d69a952625497cca0665dfdcdb9f4718" with a NATIVE savepoint. ------------------------------------------------------------ The program finished with the following exception: org.apache.flink.util.FlinkException: Could not stop with a savepoint job "d69a952625497cca0665dfdcdb9f4718". 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:1886) at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2021) at org.apache.flink.client.cli.CliFrontend.lambda$stop$4(CliFrontend.java:591) ... 7 more