diff --git a/x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/integration/TooManyJobsIT.java b/x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/integration/TooManyJobsIT.java index c4150d633a8f0..f79e9f1e4e945 100644 --- a/x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/integration/TooManyJobsIT.java +++ b/x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/integration/TooManyJobsIT.java @@ -124,11 +124,11 @@ public void testLazyNodeValidation() throws Exception { } public void testSingleNode() throws Exception { - verifyMaxNumberOfJobsLimit(1, randomIntBetween(1, 100)); + verifyMaxNumberOfJobsLimit(1, randomIntBetween(1, 20)); } public void testMultipleNodes() throws Exception { - verifyMaxNumberOfJobsLimit(3, randomIntBetween(1, 100)); + verifyMaxNumberOfJobsLimit(3, randomIntBetween(1, 20)); } private void verifyMaxNumberOfJobsLimit(int numNodes, int maxNumberOfJobsPerNode) throws Exception { diff --git a/x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/support/BaseMlIntegTestCase.java b/x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/support/BaseMlIntegTestCase.java index 44cdd2434aec7..e5627fdd41b81 100644 --- a/x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/support/BaseMlIntegTestCase.java +++ b/x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/support/BaseMlIntegTestCase.java @@ -318,7 +318,7 @@ public static void deleteAllJobs(Logger logger, Client client) throws Exception try { CloseJobAction.Request closeRequest = new CloseJobAction.Request(MetaData.ALL); - closeRequest.setCloseTimeout(TimeValue.timeValueSeconds(20L)); + closeRequest.setCloseTimeout(TimeValue.timeValueSeconds(30L)); logger.info("Closing jobs using [{}]", MetaData.ALL); CloseJobAction.Response response = client.execute(CloseJobAction.INSTANCE, closeRequest) .get(); @@ -327,7 +327,7 @@ public static void deleteAllJobs(Logger logger, Client client) throws Exception try { CloseJobAction.Request closeRequest = new CloseJobAction.Request(MetaData.ALL); closeRequest.setForce(true); - closeRequest.setCloseTimeout(TimeValue.timeValueSeconds(20L)); + closeRequest.setCloseTimeout(TimeValue.timeValueSeconds(30L)); CloseJobAction.Response response = client.execute(CloseJobAction.INSTANCE, closeRequest).get(); assertTrue(response.isClosed());