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)