package org.apache.flink.runtime.concurrent;
<BUG>import org.apache.flink.runtime.concurrent.impl.FlinkCompletableFuture;
import java.util.concurrent.Callable;
import java.util.concurrent.Executor;
public class FutureUtils {</BUG>
public static <T> Future<T> retry(

package org.apache.flink.runtime.concurrent;
import org.apache.flink.runtime.concurrent.impl.FlinkCompletableFuture;
import java.util.Collection;
import java.util.concurrent.Callable;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicInteger;
import static org.apache.flink.util.Preconditions.checkNotNull;
public class FutureUtils {
public static <T> Future<T> retry(
