Yes, I mean aborting the checkpoint alignment directly from an operator. This is because I am introducing an operator that performs some asynchronous stuff that also involves side effects on its internal state. I wanted to abort a checkpoint directly from that operator if a barrier comes in while I’m performing that asynchronous job.
Is the only way to use your code in master and send a DeclineCheckpoint message? Thank you, Lorenzo Affetti On 11 Nov 2016, at 19:33, Stephan Ewen <se...@apache.org<mailto:se...@apache.org>> wrote: What do you mean exactly with aborting a checkpoint? Continuing the processing despite failed checkpoints? You can have a look at these recent changes, they cleanly abort checkpoint alignment in certain conditions: https://issues.apache.org/jira/browse/FLINK-4976 https://github.com/apache/flink/pull/2754 Best, Stephan On Fri, Nov 11, 2016 at 5:15 PM, Lorenzo Affetti <lorenzo.affe...@polimi.it<mailto:lorenzo.affe...@polimi.it>> wrote: Hi everybody, I am using Flink v1.1.2 is it possible to programmatically abort a snapshot from the method public StreamTaskState snapshotOperatorState(long checkpointId, long timestamp) In an operator? Thank you! Lorenzo
