flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
/**
	 * Retry the given operation the given number of times in case of a failure.
	 *
	 * @param operation to executed
	 * @param retries if the operation failed
	 * @param executor to use to run the futures
	 * @param <T> type of the result
	 * @return Future containing either the result of the operation or a {@link RetryException}
	 */
Retry the given operation the given number of times in case of a failure.
Retry the given operation the given number of times in case of a failure .
public static <T> CompletableFuture<T> retry(
			final Supplier<CompletableFuture<T>> operation,
			final int retries,
			final Executor executor) {
		final CompletableFuture<T> resultFuture = new CompletableFuture<>();
		retryOperation(resultFuture, operation, retries, executor);
		return resultFuture;
	}
public static < T > CompletableFuture < T > retry ( final Supplier < CompletableFuture < T > > operation , final int retries , final Executor executor ) { final CompletableFuture < T > resultFuture = new CompletableFuture < > ( ) ; retryOperation ( resultFuture , operation , retries , executor ) ; return resultFuture ; }
Retry the given operation the given number of times in case of a failure.
Retry the given operation the given number of times in case of a failure .