public void abort(CheckpointFailureReason reason, Throwable cause) {
		try {
			CheckpointException exception = new CheckpointException(reason, cause);
			onCompletionPromise.completeExceptionally(exception);
			reportFailedCheckpoint(exception);
			assertAbortSubsumedForced(reason);
		} finally {
			dispose(true);
		}
	}
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.