fix

Author: original-brownbear

server/src/main/java/org/elasticsearch/action/search/QueryPhaseResultConsumer.java

@@ -243,6 +243,7 @@ private void consume(QuerySearchResult result) {
                 if (aggregatorsReducerContext != null) {
                     consumeAggs(result);
                 }
+                buffer.add(result);
                 var toConsume = buffer;
                 // add one if a partial merge is pending
                 int size = toConsume.size() + (hasPartialReduce ? 1 : 0);
@@ -254,13 +255,8 @@ private void consume(QuerySearchResult result) {
                         partialReduce(toConsume, numReducePhases);
                     } catch (Exception t) {
                         onMergeFailure(t);
-                        return;
-                    }
-                    if (hasFailure()) {
-                        return;
                     }
                 }
-                buffer.add(result);
             }
         }
     }