title: Set path dynamic for Flink Checkpoint for Flink Job in Yarn Cluser
body: <p>I am using Yarn for running Flink jobs. For each Flink job I am creating a checkpoint.</p>
  
  <p>I submit a Flink job that runs in my Yarn cluster. I have a polling job which checks if a job has failed on Yarn and restarts it. When the job is submitted again Yarn creates a new application_id for this Flink job.  How can I configure the re-submitted Flink job to use the checkpoint for the Flink job that was restarted. </p>
  
  <p>I have set the conf
       <code>state.savepoints.dir = hdfs://localhost:9000/checkpoint/</code> in flink-conf.yaml`</p>
  
  <p>When creating the Flink job, 
  <code>streamExecutionEnvironment.setStateBackend(new FsStateBackend("hdfs://localhost:9000/checkpoint/uuid-job-1"));</code></p>
  
  <p>When I made this setting the checkpoint is saved in path specified in conf file (<code>hdfs://localhost:9000/checkpoint/</code>) and not in the path I set when creating the Flink job. </p>
  
  <p>Any help will be greatly appreciated. Thanks!</p>