logger

tlrx · tlrx · commit b2249a64940c · 2024-06-04T16:05:43.000+02:00
diff --git a/x-pack/plugin/blob-cache/src/main/java/org/elasticsearch/blobcache/common/ProgressListenableActionFuture.java b/x-pack/plugin/blob-cache/src/main/java/org/elasticsearch/blobcache/common/ProgressListenableActionFuture.java
@@ -7,6 +7,8 @@
 
 package org.elasticsearch.blobcache.common;
 
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 import org.elasticsearch.action.ActionFuture;
 import org.elasticsearch.action.ActionListener;
 import org.elasticsearch.action.support.PlainActionFuture;
@@ -26,6 +28,8 @@
  */
 class ProgressListenableActionFuture extends PlainActionFuture<Long> {
 
+    private static final Logger logger = LogManager.getLogger(ProgressListenableActionFuture.class);
+
     private record PositionAndListener(long position, ActionListener<Long> listener) {}
 
     final long start;
@@ -208,7 +212,7 @@ private static void safeAcceptProgress(LongConsumer consumer, long progress) {
             consumer.accept(progress);
         } catch (Exception e) {
             assert false : e;
-            throw e;
+            logger.warn("Failed to consume progress value", e);
         }
     }
 
