[
https://issues.apache.org/jira/browse/FLINK-32104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Ostfeld updated FLINK-32104:
---------------------------------
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:
{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}
was:
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}
> 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
> Priority: Major
>
> 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:
>
> {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)
