public void abort ( CheckpointFailureReason reason , Throwable cause ) { try { CheckpointException exception = new CheckpointException ( reason , cause ) ; onCompletionPromise . completeExceptionally ( exception ) ; reportFailedCheckpoint ( exception ) ; assertAbortSubsumedForced ( reason ) ; } finally { dispose ( true ) ; } }
Aborts a checkpoint with reason and cause .