Skip to content

Commit a2e211d

Browse files
committed
Fix unit tests
Signed-off-by: Sooraj Sinha <[email protected]>
1 parent 0ffa818 commit a2e211d

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -156,7 +156,7 @@ private int expectedSize(final String threadPoolName, final int numberOfProcesso
156156
sizes.put(ThreadPool.Names.REMOTE_PURGE, ThreadPool::halfAllocatedProcessors);
157157
sizes.put(ThreadPool.Names.REMOTE_REFRESH_RETRY, ThreadPool::halfAllocatedProcessors);
158158
sizes.put(ThreadPool.Names.REMOTE_RECOVERY, ThreadPool::twiceAllocatedProcessors);
159-
sizes.put(ThreadPool.Names.REMOTE_STATE_READ, ThreadPool::twiceAllocatedProcessors);
159+
sizes.put(ThreadPool.Names.REMOTE_STATE_READ, n -> ThreadPool.boundedBy(4 * n, 4, 32));
160160
return sizes.get(threadPoolName).apply(numberOfProcessors);
161161
}
162162

0 commit comments

Comments
 (0)