You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "nobleyd (Jira)" <ji...@apache.org> on 2020/05/10 03:09:00 UTC

[jira] [Commented] (FLINK-17487) Do not delete old checkpoints when stop the job.

    [ https://issues.apache.org/jira/browse/FLINK-17487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17103612#comment-17103612 ] 

nobleyd commented on FLINK-17487:
---------------------------------

Someone may say if I need to restart the job using an older checkpoint, I should cancel it but not stop it(which will generate a savepoint and delete all checkpoints). While, the reason that I use 'stop' but not 'cancel' is for secure(for some unexpected errors maybe).

> Do not delete old checkpoints when stop the job.
> ------------------------------------------------
>
>                 Key: FLINK-17487
>                 URL: https://issues.apache.org/jira/browse/FLINK-17487
>             Project: Flink
>          Issue Type: Improvement
>          Components: Client / Job Submission, Runtime / Checkpointing
>            Reporter: nobleyd
>            Priority: Major
>
> When stop flink job using 'flink stop jobId', the checkpoints data is deleted. 
> When the stop action is not succeed or failed because of some unknown errors, sometimes the job resumes using the latest checkpoint, while sometimes it just fails, and the checkpoints data is gone.
> You may say why I need these checkpoints since I stop the job and a savepoint will be generated. For example, my job uses a kafka source, while the kafka missed some data, and I want to stop the job and resume it using an old checkpoint. Anyway, I mean sometimes the action stop is failed and the checkpoint data is also deleted, which is not good. 
> This feature is different from the case 'flink cancel jobId' or 'flink savepoint jobId', which won't delete the checkpoint data.
>  



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