diff --git a/extensions-contrib/azure-extensions/src/main/java/org/apache/druid/storage/azure/AzureUtils.java b/extensions-contrib/azure-extensions/src/main/java/org/apache/druid/storage/azure/AzureUtils.java index 562d207d8a5..2e732feea9c 100644 --- a/extensions-contrib/azure-extensions/src/main/java/org/apache/druid/storage/azure/AzureUtils.java +++ b/extensions-contrib/azure-extensions/src/main/java/org/apache/druid/storage/azure/AzureUtils.java @@ -30,29 +30,23 @@ import java.net.URISyntaxException; public class AzureUtils { - - public static final Predicate AZURE_RETRY = new Predicate() - { - @Override - public boolean apply(Throwable e) - { - if (e instanceof URISyntaxException) { - return false; - } - - if (e instanceof IOException) { - return false; - } - - if (e instanceof StorageException) { - return true; - } - + public static final Predicate AZURE_RETRY = e -> { + if (e instanceof URISyntaxException) { return false; } + + if (e instanceof StorageException) { + return true; + } + + if (e instanceof IOException) { + return true; + } + + return false; }; - public static T retryAzureOperation(Task f, int maxTries) throws Exception + static T retryAzureOperation(Task f, int maxTries) throws Exception { return RetryUtils.retry(f, AZURE_RETRY, maxTries); }