You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2020/06/12 13:49:05 UTC
[flink] 02/05: [hotfix] Add @Nullable annotation to
FutureUtils.getWithoutException
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 <tr...@apache.org>
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 {