Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-26316

Savepoint restore setting does not take effect when configured via dynamic config options

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • Command Line Client
    • 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.

      Attachments

        Activity

          People

            Unassigned Unassigned
            wangyang0918 Yang Wang
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: