We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0ee4599 commit 08664f9Copy full SHA for 08664f9
server/src/main/java/org/elasticsearch/index/engine/ThreadPoolMergeExecutorService.java
@@ -611,7 +611,7 @@ void updateBudget(long availableBudget) {
611
// update the per-element budget (these are all the elements that are using any budget)
612
unreleasedBudgetPerElement.replaceAll((e, v) -> budgetFunction.applyAsLong(e.element()));
613
// available budget is decreased by the used per-element budget (for all dequeued elements that are still in use)
614
- this.availableBudget -= unreleasedBudgetPerElement.values().stream().reduce(0L, Long::sum);
+ this.availableBudget -= unreleasedBudgetPerElement.values().stream().mapToLong(i -> i).sum();
615
elementAvailable.signalAll();
616
} finally {
617
lock.unlock();
0 commit comments