Skip to content

Commit 18c0779

Browse files
committed
Do not account for expansions
1 parent c8a3d74 commit 18c0779

File tree

2 files changed

+0
-6
lines changed

2 files changed

+0
-6
lines changed

server/src/main/java/org/elasticsearch/index/IndexingPressure.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -382,10 +382,6 @@ private Releasable markPrimaryOperationStarted(int operations, long bytes, boole
382382
this.currentCombinedCoordinatingAndPrimaryBytes.getAndAdd(-bytes);
383383
this.primaryRejections.getAndIncrement();
384384
this.primaryDocumentRejections.addAndGet(operations);
385-
if (operationExpansionTracking) {
386-
this.largeOpsRejections.getAndIncrement();
387-
this.totalRejectedLargeOpsBytes.addAndGet(bytes);
388-
}
389385
throw new EsRejectedExecutionException(
390386
"rejected execution of primary operation ["
391387
+ "coordinating_and_primary_bytes="

server/src/test/java/org/elasticsearch/index/IndexingPressureTests.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -259,8 +259,6 @@ public void testPrimaryOperationExpansionAccountingRejections() {
259259

260260
assertEquals(1024 * 11, indexingPressure.stats().getTotalPrimaryBytes());
261261
assertEquals(2, indexingPressure.stats().getTotalPrimaryOps());
262-
assertEquals(1, indexingPressure.stats().getLargeOpsRejections());
263-
assertEquals(1024 * 8, indexingPressure.stats().getTotalLargeRejectedOpsBytes());
264262
}
265263

266264
public void testReplicaOperationExpansionAccounting() {

0 commit comments

Comments
 (0)