Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
Reported by user in this ML thread.
If you use the following command to start a Flink k8s application, the savepoint restore settings does not take effect.
$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
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.