Ali Bahadir Zeybek created FLINK-30337:
------------------------------------------
Summary: Stateful Functions application throws an exception when
stopping a job gracefully creating a final savepoint
Key: FLINK-30337
URL: https://issues.apache.org/jira/browse/FLINK-30337
Project: Flink
Issue Type: Bug
Components: Stateful Functions
Affects Versions: statefun-3.2.0
Reporter: Ali Bahadir Zeybek
When running a Stateful Functions applications, if the stop[1] command is
executed, the client throws a FlinkException with the following stack trace
where *953498833da99ec437758b49b7d5befd* is the specific job id:
{code:java}
The program finished with the following
exception:org.apache.flink.util.FlinkException: Could not stop with a savepoint
job "953498833da99ec437758b49b7d5befd".
at
org.apache.flink.client.cli.CliFrontend.lambda$stop$5(CliFrontend.java:581)
at
org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:1002)
at org.apache.flink.client.cli.CliFrontend.stop(CliFrontend.java:569)
at
org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1069)
at
org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1132)
at
org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1132)
Caused by: java.util.concurrent.TimeoutException
at java.base/java.util.concurrent.CompletableFuture.timedGet(Unknown Source)
at java.base/java.util.concurrent.CompletableFuture.get(Unknown Source)
at
org.apache.flink.client.cli.CliFrontend.lambda$stop$5(CliFrontend.java:579)
... 6 more {code}
How to reproduce:
# Follow the README[2] of the k8s deployment example of the
*flink-statefun-playground* project to have a running application
# Open the Flink UI that is started to get the *JOB_ID*
**
# Detect the *STATEFUN_MASTER_POD_NAME* by running
{code:java}
kubectl get pods --namespace statefun {code}
# Start a shell into the *statefun-master* pod by issuing the
{code:java}
kubectl exec -it --namespace statefun $STATEFUN_MASTER_POD_NAME -- /bin/bash
{code}
# Run the stop command
{code:java}
./bin/flink stop --savepointPath /tmp/flink-savepoints $JOB_ID{code}
[1]:
[https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/deployment/cli/#stopping-a-job-gracefully-creating-a-final-savepoint]
[2]:
[https://github.com/apache/flink-statefun-playground/blob/main/deployments/k8s/README.md]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
