Github user zentol commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5589#discussion_r170938595
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
 ---
    @@ -223,6 +223,77 @@
                }
        }
     
    +   /**
    +    * Retry the given operation with the given delay in between successful 
completions where the
    +    * result does not match a given predicate.
    +    *
    +    * @param operation to retry
    +    * @param retries number of retries
    +    * @param retryDelay delay between retries
    +    * @param retryPredicate Predicate to test whether the result is 
acceptable
    +    * @param scheduledExecutor executor to be used for the retry operation
    +    * @param <T> type of the result
    +    * @return Future which retries the given operation a given amount of 
times and delays the retry in case of failures
    --- End diff --
    
    "failures" is misleading in this context


---

Reply via email to