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