From 7fa0ff5e11d4552fa62e0fb78ff99219197f62b7 Mon Sep 17 00:00:00 2001 From: Clint Wylie Date: Tue, 13 Aug 2019 21:48:45 -0700 Subject: [PATCH] adjust azure storage retry conditions (#8296) --- .../druid/storage/azure/AzureUtils.java | 32 ++++++++----------- 1 file changed, 13 insertions(+), 19 deletions(-) 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); }