You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Yang Wang (Jira)" <ji...@apache.org> on 2022/02/23 06:22:00 UTC

[jira] [Created] (FLINK-26316) Savepoint restore setting does not take effect when configured via dynamic config options

Yang Wang created FLINK-26316:
---------------------------------

             Summary: Savepoint restore setting does not take effect when configured via dynamic config options
                 Key: FLINK-26316
                 URL: https://issues.apache.org/jira/browse/FLINK-26316
             Project: Flink
          Issue Type: Bug
          Components: Command Line Client
            Reporter: Yang Wang


If you use the following command to start a Flink k8s application, the savepoint restore settings does not take effect.
{code:java}
$FLINK_HOME/bin/flink run-application -t kubernetes-application \
-Dkubernetes.cluster-id=$CLUSTER_ID \
-Dkubernetes.namespace=$NAMESPACE \
-Dkubernetes.container.image=$IMAGE \
-Dexecution.savepoint.ignore-unclaimed-state=true \
-Dexecution.savepoint.path=oss://flink-test/flink-ha \
local:///opt/flink/examples/streaming/StateMachineExample.jar
{code}
Not only the K8s application, it also does not work for yarn application and yarn per-job mode.

 

The root cause is that {{SavepointRestoreSettings#none()}} will override the effective configuration wrongly in {{{}ProgramOptions#applyToConfiguration{}}}.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)