You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/09/24 10:13:24 UTC
[flink] branch master updated: [FLINK-10234][runtime] Fix ambiguous
lambda usage
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 55edc92 [FLINK-10234][runtime] Fix ambiguous lambda usage
55edc92 is described below
commit 55edc921a55a2830aefe6e30da6281b6dd6537dc
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Mon Aug 27 15:35:18 2018 +0200
[FLINK-10234][runtime] Fix ambiguous lambda usage
---
.../main/java/org/apache/flink/runtime/concurrent/FutureUtils.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 d4a65de..41effc1 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
@@ -200,7 +200,7 @@ public class FutureUtils {
} else {
if (retries > 0 && retryPredicate.test(throwable)) {
final ScheduledFuture<?> scheduledFuture = scheduledExecutor.schedule(
- () -> retryOperationWithDelay(resultFuture, operation, retries - 1, retryDelay, retryPredicate, scheduledExecutor),
+ (Runnable) () -> retryOperationWithDelay(resultFuture, operation, retries - 1, retryDelay, retryPredicate, scheduledExecutor),
retryDelay.toMilliseconds(),
TimeUnit.MILLISECONDS);
@@ -282,7 +282,7 @@ public class FutureUtils {
resultFuture.complete(t);
} else if (deadline.hasTimeLeft()) {
final ScheduledFuture<?> scheduledFuture = scheduledExecutor.schedule(
- () -> retrySuccessfulOperationWithDelay(resultFuture, operation, retryDelay, deadline, acceptancePredicate, scheduledExecutor),
+ (Runnable) () -> retrySuccessfulOperationWithDelay(resultFuture, operation, retryDelay, deadline, acceptancePredicate, scheduledExecutor),
retryDelay.toMilliseconds(),
TimeUnit.MILLISECONDS);