Skip to content

Commit 189ff78

Browse files
author
Max Hniebergall
committed
Increase default queue capacity and decrease max queue capacity
1 parent d3fcead commit 189ff78

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ml/action/StartTrainedModelDeploymentAction.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ public class StartTrainedModelDeploymentAction extends ActionType<CreateTrainedM
7171
public static final AllocationStatus.State DEFAULT_WAITFOR_STATE = AllocationStatus.State.STARTED;
7272
public static final int DEFAULT_NUM_ALLOCATIONS = 1;
7373
public static final int DEFAULT_NUM_THREADS = 1;
74-
public static final int DEFAULT_QUEUE_CAPACITY = 1024;
74+
public static final int DEFAULT_QUEUE_CAPACITY = 10000;
7575
public static final Priority DEFAULT_PRIORITY = Priority.NORMAL;
7676

7777
public StartTrainedModelDeploymentAction() {
@@ -89,7 +89,7 @@ public static class Request extends MasterNodeRequest<Request> implements ToXCon
8989
/**
9090
* If the queue is created then we can OOM when we create the queue.
9191
*/
92-
private static final int MAX_QUEUE_CAPACITY = 1_000_000;
92+
private static final int MAX_QUEUE_CAPACITY = 100_000;
9393

9494
public static final ParseField MODEL_ID = new ParseField("model_id");
9595
public static final ParseField DEPLOYMENT_ID = new ParseField("deployment_id");

0 commit comments

Comments
 (0)