[jira] [Created] (FLINK-23904) Add a parameter to flink's startup command that points to the directory named jobid containing all versions of checkpoint

[liwei li (Jira)]

liwei li created FLINK-23904:
--------------------------------

             Summary: Add a parameter to flink's startup command that points to 
the directory named jobid containing all versions of checkpoint
                 Key: FLINK-23904
                 URL: https://issues.apache.org/jira/browse/FLINK-23904
             Project: Flink
          Issue Type: Improvement
            Reporter: liwei li


hi,all

Can we add a parameter to flink's startup command that points to the directory 
named jobid containing all versions of checkpoint, and the program 
automatically traverses this directory to find the latest available checkpoint?

For instance,

If the program needs to start from checkpoint, I need to specify HDFS 
:///checkpoint/\{jobid}/chk-12.

The new parameter only needs to be specified to HDFS :///checkpoint/\{jobid}/

Flink then traverses the directory and looks for the latest available 
checkpoint.

I mention this issue because our script currently needs to go through the 
directory named jobid to find a checkpoint that can be used to restore the 
flink task.

thx.

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)