TODOs

Author: original-brownbear

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

@@ -793,7 +793,7 @@ public static void registerNodeSearchAction(SearchTransportService searchTranspo
                         ((CancellableTask) task)::isCancelled,
                         SearchProgressListener.NOOP,
                         shardCount,
-                        Integer.MAX_VALUE,
+                        Integer.MAX_VALUE, // TODO: intermediary reduces
                         e -> logger.error("failed to merge on data node", e)
                     ),
                     request,
@@ -875,6 +875,7 @@ private void setFailure(QueryPerNodeState state, int dataNodeLocalIdx, Exception
                         @Override
                         public void onFailure(Exception e) {
                             try {
+                                // TODO: count down fully and just respond with an exception if partial results aren't allowed
                                 setFailure(state, dataNodeLocalIdx, e);
                                 maybeNext();
                             } catch (Throwable expected) {