flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
/**
	 * Returns an exceptionally completed {@link CompletableFuture}.
	 *
	 * @param cause to complete the future with
	 * @param <T> type of the future
	 * @return An exceptionally completed CompletableFuture
	 */
Returns an exceptionally completed  CompletableFuture.
@param cause to complete the future with
@param  type of the future
@return An exceptionally completed CompletableFuture
Returns an exceptionally completed CompletableFuture . @param cause to complete the future with @param type of the future @return An exceptionally completed CompletableFuture
public static <T>CompletableFuture<T> completedExceptionally(Throwable cause) {
		CompletableFuture<T> result = new CompletableFuture<>();
		result.completeExceptionally(cause);
		return result;
	}
public static < T > CompletableFuture < T > completedExceptionally ( Throwable cause ) { CompletableFuture < T > result = new CompletableFuture < > ( ) ; result . completeExceptionally ( cause ) ; return result ; }
Returns an exceptionally completed {@link CompletableFuture}.
Returns an exceptionally completed { @link CompletableFuture } .