Kurt Ostfeld created FLINK-32104:
------------------------------------
Summary: stop-with-savepoint fails and times out with simple
reproducible example
Key: FLINK-32104
URL: https://issues.apache.org/jira/browse/FLINK-32104
Project: Flink
Issue Type: Bug
Components: API / DataStream
Affects Versions: 1.17.0
Reporter: Kurt Ostfeld
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 with a very simple application written with the Flink DataStream
API, `stop-with-savepoint` fails and times out like this:
{code:java}
./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 {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
