File tree Expand file tree Collapse file tree 2 files changed +12
-10
lines changed
server/src/main/java/org/elasticsearch/search/fetch Expand file tree Collapse file tree 2 files changed +12
-10
lines changed Original file line number Diff line number Diff line change @@ -102,15 +102,17 @@ public void execute(
102102 final int maxInFlightChunks = 1 ; // TODO make configurable
103103 final ArrayDeque <CompletableFuture <Void >> pendingChunks = new ArrayDeque <>();
104104 final AtomicReference <Throwable > sendFailure = new AtomicReference <>();
105- hits = buildSearchHits (context ,
105+ hits = buildSearchHits (
106+ context ,
106107 docIdsToLoad ,
107108 profiler ,
108109 rankDocs ,
109110 memoryChecker ,
110111 writer ,
111112 pendingChunks ,
112113 maxInFlightChunks ,
113- sendFailure );
114+ sendFailure
115+ );
114116
115117 // Wait for all chunks to be ACKed before setting final result
116118 if (writer != null && pendingChunks .isEmpty () == false ) {
Original file line number Diff line number Diff line change @@ -191,14 +191,14 @@ public final IterateResult iterate(
191191
192192 // Send chunk with sequence information
193193 CompletableFuture <Void > chunkFuture = sendChunk (
194- chunkWriter ,
195- chunkBuffer ,
196- shardId ,
197- currentChunkSequenceStart ,
198- i - chunkBuffer .size () + 1 ,
199- docIds .length ,
200- Float .NaN
201- );
194+ chunkWriter ,
195+ chunkBuffer ,
196+ shardId ,
197+ currentChunkSequenceStart ,
198+ i - chunkBuffer .size () + 1 ,
199+ docIds .length ,
200+ Float .NaN
201+ );
202202
203203 // record failures as soon as they happen
204204 chunkFuture .whenComplete ((ok , ex ) -> {
You can’t perform that action at this time.
0 commit comments