This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 76efc7811bcd159089d2b6687211ebb99ba04352 Author: Till Rohrmann <[email protected]> AuthorDate: Thu Jun 11 16:20:46 2020 +0200 [hotfix] Add @Nullable annotation to FutureUtils.getWithoutException --- .../src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java b/flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java index 7ea36e0..05be10d 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java @@ -28,6 +28,8 @@ import org.apache.flink.util.function.SupplierWithException; import akka.dispatch.OnComplete; +import javax.annotation.Nullable; + import java.time.Duration; import java.util.Arrays; import java.util.Collection; @@ -1007,6 +1009,7 @@ public class FutureUtils { * @return the result of completable future, * or null if it's unfinished or finished exceptionally */ + @Nullable public static <T> T getWithoutException(CompletableFuture<T> future) { if (future.isDone() && !future.isCompletedExceptionally()) { try {
