abstract runnable

Author: ywangd

modules/repository-s3/src/main/java/org/elasticsearch/repositories/s3/S3PerProjectClientManager.java

@@ -18,6 +18,7 @@
 import org.elasticsearch.common.settings.ProjectSecrets;
 import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.common.util.Maps;
+import org.elasticsearch.common.util.concurrent.AbstractRunnable;
 import org.elasticsearch.core.IOUtils;
 import org.elasticsearch.core.Nullable;
 import org.elasticsearch.logging.LogManager;
@@ -143,9 +144,18 @@ public void applyClusterState(ClusterChangedEvent event) {
     }
 
     private void closeClientsAsync(List<ClientsHolder> clientsHoldersToClose, ActionListener<Void> listener) {
-        executor.execute(() -> {
-            IOUtils.closeWhileHandlingException(clientsHoldersToClose);
-            listener.onResponse(null);
+        executor.execute(new AbstractRunnable() {
+            @Override
+            protected void doRun() throws Exception {
+                IOUtils.closeWhileHandlingException(clientsHoldersToClose);
+                listener.onResponse(null);
+            }
+
+            @Override
+            public void onFailure(Exception e) {
+                logger.warn("Failed to close s3 clients", e);
+                listener.onFailure(e);
+            }
         });
     }