diff --git a/x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/inference/bulk/BulkInferenceExecutorTests.java b/x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/inference/bulk/BulkInferenceExecutorTests.java index e539a8ec775b6..7e44c681c6fc4 100644 --- a/x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/inference/bulk/BulkInferenceExecutorTests.java +++ b/x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/inference/bulk/BulkInferenceExecutorTests.java @@ -61,7 +61,7 @@ public void shutdownThreadPool() { } public void testSuccessfulExecution() throws Exception { - List requests = randomInferenceRequestList(between(1, 10_000)); + List requests = randomInferenceRequestList(between(1, 1000)); List responses = randomInferenceResponseList(requests.size()); InferenceRunner inferenceRunner = mockInferenceRunner(invocation -> { @@ -93,7 +93,7 @@ public void testSuccessfulExecutionOnEmptyRequest() throws Exception { } public void testInferenceRunnerAlwaysFails() throws Exception { - List requests = randomInferenceRequestList(between(1, 10_000)); + List requests = randomInferenceRequestList(between(1, 1000)); InferenceRunner inferenceRunner = mock(invocation -> { runWithRandomDelay(() -> { @@ -115,7 +115,7 @@ public void testInferenceRunnerAlwaysFails() throws Exception { } public void testInferenceRunnerSometimesFails() throws Exception { - List requests = randomInferenceRequestList(between(1, 10_000)); + List requests = randomInferenceRequestList(between(1, 1000)); InferenceRunner inferenceRunner = mockInferenceRunner(invocation -> { ActionListener listener = invocation.getArgument(1);