log actual error

ywangd · Oct 8, 2024 · 10ae254 · 10ae254
1 parent e7fea24
commit 10ae254
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/server/src/main/java/org/elasticsearch/action/support/PlainActionFuture.java b/server/src/main/java/org/elasticsearch/action/support/PlainActionFuture.java
@@ -20,6 +20,8 @@
 import org.elasticsearch.common.util.concurrent.UncategorizedExecutionException;
 import org.elasticsearch.core.Nullable;
 import org.elasticsearch.core.TimeValue;
+import org.elasticsearch.logging.LogManager;
+import org.elasticsearch.logging.Logger;
 import org.elasticsearch.threadpool.ThreadPool;
 import org.elasticsearch.transport.Transports;
 
@@ -32,14 +34,21 @@
 
 public class PlainActionFuture<T> implements ActionFuture<T>, ActionListener<T> {
 
+    private static final Logger logger = LogManager.getLogger(PlainActionFuture.class);
+
     @Override
     public void onResponse(@Nullable T result) {
         set(result);
     }
 
     @Override
     public void onFailure(Exception e) {
-        assert assertCompleteAllowed();
+        try {
+            assert assertCompleteAllowed();
+        } catch (AssertionError ae) {
+            logger.warn("--> AssertionError for onFailure", e);
+            throw ae;
+        }
         if (sync.setException(Objects.requireNonNull(e))) {
             done(false);
         }