On 14 November 2016 at 11:30:13, Lorenzo Affetti (lorenzo.affe...@polimi.it) wrote: > Thank you for the pointers and the clarification! > > One question, when you say: "There is currently no way to be explicitly > notified about > an incoming barrier”, isn’t `snapshotOperatorState` invoked when a barrier > approaches > the operator?
Sorry for the confusion, I meant this in the context of keyed state. When you use the new CheckpointedFunction interface or the old Checkpointed interface, you indeed have the snapshot callbacks when the barrier arrives. You can use this to notify the async threads, etc. but not explicitly cancel a checkpoint. – Ufuk
