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> 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 > > >
