You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Ali Bahadir Zeybek (Jira)" <ji...@apache.org> on 2022/12/08 09:33:00 UTC
[jira] [Updated] (FLINK-30337) Stateful Functions application throws an exception when stopping a job gracefully creating a final savepoint
[ https://issues.apache.org/jira/browse/FLINK-30337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ali Bahadir Zeybek updated FLINK-30337:
---------------------------------------
Description:
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]
was:
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]
> 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
> Priority: Minor
>
> 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)