[
https://issues.apache.org/jira/browse/FLINK-32104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Ostfeld resolved FLINK-32104.
----------------------------------
Resolution: Invalid
[~Weijie Guo] , thank you so much for your help. If I move the sleep before the
keyBy, I can suspend. Thanks!
> 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)
