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