Skip to content

Commit 0ffa818

Browse files
committed
Reconfigure remote state thread pool count
Signed-off-by: Sooraj Sinha <[email protected]>
1 parent 146b0f7 commit 0ffa818

File tree

2 files changed

+2
-7
lines changed

2 files changed

+2
-7
lines changed

plugins/repository-s3/src/main/java/org/opensearch/repositories/s3/S3RepositoryPlugin.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -188,7 +188,7 @@ private static int allocatedProcessors(Settings settings) {
188188
}
189189

190190
private static int urgentPoolCount(Settings settings) {
191-
return boundedBy((allocatedProcessors(settings) + 7) / 8, 1, 2);
191+
return boundedBy((allocatedProcessors(settings) + 1) / 2, 1, 2);
192192
}
193193

194194
private static int priorityPoolCount(Settings settings) {

server/src/main/java/org/opensearch/threadpool/ThreadPool.java

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -293,12 +293,7 @@ public ThreadPool(
293293
);
294294
builders.put(
295295
Names.REMOTE_STATE_READ,
296-
new ScalingExecutorBuilder(
297-
Names.REMOTE_STATE_READ,
298-
1,
299-
twiceAllocatedProcessors(allocatedProcessors),
300-
TimeValue.timeValueMinutes(5)
301-
)
296+
new ScalingExecutorBuilder(Names.REMOTE_STATE_READ, 1, boundedBy(4 * allocatedProcessors, 4, 32), TimeValue.timeValueMinutes(5))
302297
);
303298
builders.put(
304299
Names.INDEX_SEARCHER,

0 commit comments

Comments
 (0)