public void abortPendingCheckpoints ( CheckpointException exception ) { synchronized ( lock ) { for ( PendingCheckpoint p : pendingCheckpoints . values ( ) ) { p . abort ( exception . getCheckpointFailureReason ( ) ) ; } pendingCheckpoints . clear ( ) ; } }
Aborts all the pending checkpoints due to en exception .