Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4918
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4918#discussion_r147658822
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -446,19 +449,67 @@ public void onComplete(Throwable f
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4918#discussion_r147658765
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -446,19 +449,67 @@ public void onComplete(Throwable f
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4918#discussion_r147658453
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -446,19 +449,67 @@ public void onComplete(Throwable f
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4918#discussion_r147594462
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -446,19 +449,67 @@ public void onComplete(Throwable failure
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4918#discussion_r147594496
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -446,19 +449,67 @@ public void onComplete(Throwable failure
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4918#discussion_r147594412
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -446,19 +449,67 @@ public void onComplete(Throwable failure
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4918
[FLINK-7940] Add FutureUtils.orTimeout
## What is the purpose of the change
This commit adds a convenience function `FutureUtils#orTimeout` which
allows to easily add a timeout to
