wangyang0918 commented on a change in pull request #13644:
URL: https://github.com/apache/flink/pull/13644#discussion_r511803649
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
##########
@@ -412,6 +415,26 @@ public RetryException(Throwable cause) {
}
}
+ /**
+ * The {@link #retry(Supplier, int, Executor)} attempts will stop at
this exception.
+ */
+ public static class NotRetryException extends Exception {
Review comment:
Just like `FutureUtils#retryWithDelay`, I have added a new parameter
`Predicate<Throwable> retryPredicate` for `FutureUtils#retry`. Then it is
flexible enough to control when to stop the retry.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
