flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
/** Method which increments the atomic completion counter and completes or fails the WaitingFutureImpl. */
Method which increments the atomic completion counter and completes or fails the WaitingFutureImpl.
Method which increments the atomic completion counter and completes or fails the WaitingFutureImpl .
private void handleCompletedFuture(Object ignored, Throwable throwable) {
			if (throwable == null) {
				if (numTotal == numCompleted.incrementAndGet()) {
					complete(null);
				}
			} else {
				completeExceptionally(throwable);
			}
		}
private void handleCompletedFuture ( Object ignored , Throwable throwable ) { if ( throwable == null ) { if ( numTotal == numCompleted . incrementAndGet ( ) ) { complete ( null ) ; } } else { completeExceptionally ( throwable ) ; } }
Method which increments the atomic completion counter and completes or fails the WaitingFutureImpl.
Method which increments the atomic completion counter and completes or fails the WaitingFutureImpl .