[jira] [Commented] (FLINK-9375) Introduce AbortCheckpoint message from JM to TMs

["Stefan Richter (JIRA)" <ji...@apache.org>]

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

Stefan Richter commented on FLINK-9375:
---------------------------------------

[~yanghua] this task maybe a bit more tricky than it sounds. If you still want to work on this, I think it would make a lot of sense if you would briefly outline your implementation plan here before you start coding.

> Introduce AbortCheckpoint message from JM to TMs
> ------------------------------------------------
>
>                 Key: FLINK-9375
>                 URL: https://issues.apache.org/jira/browse/FLINK-9375
>             Project: Flink
>          Issue Type: Improvement
>          Components: State Backends, Checkpointing
>            Reporter: Stefan Richter
>            Assignee: vinoyang
>            Priority: Major
>
> We should introduce an {{AbortCheckpoint}} message that a jobmanager can send to taskmanagers if a checkpoint is canceled so that the operators can eagerly stop their alignment phase and continue to normal processing. This can reduce some backpressure issues in the context of canceled and restarted checkpoints.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)