Skip to content

Commit 79e495a

Browse files
revert debug change + dry
1 parent aee2d18 commit 79e495a

File tree

2 files changed

+6
-9
lines changed

2 files changed

+6
-9
lines changed

server/src/main/java/org/elasticsearch/common/lucene/Lucene.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -391,7 +391,7 @@ public static ScoreDoc readScoreDoc(StreamInput in) throws IOException {
391391
}
392392

393393
public static ScoreDoc readScoreDocWithShardIndex(StreamInput in) throws IOException {
394-
var res = new ScoreDoc(in.readVInt(), in.readFloat());
394+
var res = readScoreDoc(in);
395395
res.shardIndex = in.readVInt();
396396
return res;
397397
}

server/src/main/java/org/elasticsearch/search/SearchService.java

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -322,8 +322,6 @@ public class SearchService extends AbstractLifecycleComponent implements IndexEv
322322

323323
private final Tracer tracer;
324324

325-
private final CircuitBreaker circuitBreaker;
326-
327325
public SearchService(
328326
ClusterService clusterService,
329327
IndicesService indicesService,
@@ -342,8 +340,11 @@ public SearchService(
342340
this.scriptService = scriptService;
343341
this.bigArrays = bigArrays;
344342
this.fetchPhase = fetchPhase;
345-
this.circuitBreaker = circuitBreakerService.getBreaker(CircuitBreaker.REQUEST);
346-
this.multiBucketConsumerService = new MultiBucketConsumerService(clusterService, settings, circuitBreaker);
343+
this.multiBucketConsumerService = new MultiBucketConsumerService(
344+
clusterService,
345+
settings,
346+
circuitBreakerService.getBreaker(CircuitBreaker.REQUEST)
347+
);
347348
this.executorSelector = executorSelector;
348349
this.tracer = tracer;
349350

@@ -390,10 +391,6 @@ public SearchService(
390391
.addSettingsUpdateConsumer(QUERY_PHASE_PARALLEL_COLLECTION_ENABLED, this::setEnableQueryPhaseParallelCollection);
391392
}
392393

393-
public CircuitBreaker circuitBreaker() {
394-
return circuitBreaker;
395-
}
396-
397394
private void setEnableSearchWorkerThreads(boolean enableSearchWorkerThreads) {
398395
if (enableSearchWorkerThreads) {
399396
searchExecutor = threadPool.executor(Names.SEARCH);

0 commit comments

Comments
 (0)