Skip to content

Commit baffc4a

Browse files
authored
Fix failure in ScalingThreadPoolTests after addition of merge scheduler (#125245)
1 parent 2fd70d9 commit baffc4a

File tree

2 files changed

+1
-3
lines changed

2 files changed

+1
-3
lines changed

muted-tests.yml

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -387,9 +387,6 @@ tests:
387387
- class: org.elasticsearch.xpack.ilm.DataStreamAndIndexLifecycleMixingTests
388388
method: testGetDataStreamResponse
389389
issue: https://github.com/elastic/elasticsearch/issues/125083
390-
- class: org.elasticsearch.threadpool.ScalingThreadPoolTests
391-
method: testScalingThreadPoolConfiguration
392-
issue: https://github.com/elastic/elasticsearch/issues/125142
393390
- class: org.elasticsearch.packaging.test.DockerTests
394391
method: test012SecurityCanBeDisabled
395392
issue: https://github.com/elastic/elasticsearch/issues/116636

server/src/test/java/org/elasticsearch/threadpool/ScalingThreadPoolTests.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,7 @@ private int expectedSize(final String threadPoolName, final int numberOfProcesso
119119
sizes.put(ThreadPool.Names.SNAPSHOT_META, n -> Math.min(n * 3, 50));
120120
sizes.put(ThreadPool.Names.FETCH_SHARD_STARTED, ThreadPool::twiceAllocatedProcessors);
121121
sizes.put(ThreadPool.Names.FETCH_SHARD_STORE, ThreadPool::twiceAllocatedProcessors);
122+
sizes.put(ThreadPool.Names.MERGE, Function.identity());
122123
return sizes.get(threadPoolName).apply(numberOfProcessors);
123124
}
124125

0 commit comments

Comments
 (0)