Skip to content

Commit

Permalink
Remove incorrect return that breaks non-limit related partial results…
Browse files Browse the repository at this point in the history
… use cases such as tolerant search.
  • Loading branch information
gus-asf committed Nov 7, 2024
1 parent f8b854b commit 86080b0
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -600,7 +600,8 @@ private void processComponents(
? shardHandler1.takeCompletedIncludingErrors()
: shardHandler1.takeCompletedOrError();
if (srsp == null) break; // no more requests to wait for
AtomicReference<Object> detailMesg = new AtomicReference<>(); // or perhaps new Object[1] ?
AtomicReference<Object> detailMesg =
new AtomicReference<>(); // or perhaps new Object[1] ?

boolean anyResponsesPartial =
srsp.getShardRequest().responses.stream()
Expand Down Expand Up @@ -653,7 +654,6 @@ private void processComponents(
rsp.getResponseHeader().add(ThreadCpuTimer.CPU_TIME, totalShardCpuTime);
rsp.addToLog(ThreadCpuTimer.CPU_TIME, totalShardCpuTime);
}
return; // nothing for components to see, don't need to finish stages
}
}
}
Expand Down

0 comments on commit 86080b0

Please sign in to comment.