vinoyang commented on FLINK-8459:

Hi [~till.rohrmann] , my idea is like yours in a way, refer to the JobManager 
handle CancelJobWithSavepoint message in old version (such as v1.3.2). The 
request contains trigger savepoint and cancel job two actions and the eventual 
cancel should happen after the savepoint invoke successfully.

> Implement cancelWithSavepoint in RestClusterClient
> --------------------------------------------------
>                 Key: FLINK-8459
>                 URL: https://issues.apache.org/jira/browse/FLINK-8459
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Client
>    Affects Versions: 1.5.0
>            Reporter: Gary Yao
>            Assignee: vinoyang
>            Priority: Blocker
>              Labels: flip-6
>             Fix For: 1.5.0
> Implement the method
>         {{RestClusterClient#cancelWithSavepoint(JobID jobId, @Nullable String 
> savepointDirectory)}}.
> by either taking a savepoint and cancel the job separately, or by migrating 
> the logic in {{JobCancellationWithSavepointHandlers}}. The former will have 
> different semantics because the checkpoint scheduler is not stopped. Thus it 
> is not guaranteed that there won't be additional checkpoints between the 
> savepoint and the job cancelation.

This message was sent by Atlassian JIRA

Reply via email to