honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[REMOVE] Cleanup deprecated thread pool types (FIXED_AUTO_QUEUE_SIZE) (#3369) 

Signed-off-by: Andriy Redko <andriy.redko@aiven.io>
This commit is contained in:
Andriy Redko 2022-05-19 17:20:26 -04:00 committed by GitHub
parent 507f8ccdbd
commit 96b45ca103
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
server/src/main/java/org/opensearch/threadpool/ThreadPool.java
View File

@ -118,7 +118,6 @@ public class ThreadPool implements ReportingService<ThreadPoolInfo>, Scheduler {
DIRECT("direct"),
FIXED("fixed"),
RESIZABLE("resizable"),
FIXED_AUTO_QUEUE_SIZE("fixed_auto_queue_size"),
SCALING("scaling");
private final String type;
@ -696,7 +695,13 @@ public class ThreadPool implements ReportingService<ThreadPoolInfo>, Scheduler {
public Info(StreamInput in) throws IOException {
name = in.readString();
type = ThreadPoolType.fromType(in.readString());
final String typeStr = in.readString();
// Opensearch on or after 3.0.0 version doesn't know about "fixed_auto_queue_size" thread pool. Convert it to RESIZABLE.
if (typeStr.equalsIgnoreCase("fixed_auto_queue_size")) {
type = ThreadPoolType.RESIZABLE;
} else {
type = ThreadPoolType.fromType(typeStr);
}
min = in.readInt();
max = in.readInt();
keepAlive = in.readOptionalTimeValue();