Skip to content

Commit b32960b

Browse files
committed
[ML] Increase close job timeout and lower the max number (#37770)
1 parent d8feff5 commit b32960b

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/integration/TooManyJobsIT.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -124,11 +124,11 @@ public void testLazyNodeValidation() throws Exception {
124124
}
125125

126126
public void testSingleNode() throws Exception {
127-
verifyMaxNumberOfJobsLimit(1, randomIntBetween(1, 100));
127+
verifyMaxNumberOfJobsLimit(1, randomIntBetween(1, 20));
128128
}
129129

130130
public void testMultipleNodes() throws Exception {
131-
verifyMaxNumberOfJobsLimit(3, randomIntBetween(1, 100));
131+
verifyMaxNumberOfJobsLimit(3, randomIntBetween(1, 20));
132132
}
133133

134134
private void verifyMaxNumberOfJobsLimit(int numNodes, int maxNumberOfJobsPerNode) throws Exception {

x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/support/BaseMlIntegTestCase.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -318,7 +318,7 @@ public static void deleteAllJobs(Logger logger, Client client) throws Exception
318318

319319
try {
320320
CloseJobAction.Request closeRequest = new CloseJobAction.Request(MetaData.ALL);
321-
closeRequest.setCloseTimeout(TimeValue.timeValueSeconds(20L));
321+
closeRequest.setCloseTimeout(TimeValue.timeValueSeconds(30L));
322322
logger.info("Closing jobs using [{}]", MetaData.ALL);
323323
CloseJobAction.Response response = client.execute(CloseJobAction.INSTANCE, closeRequest)
324324
.get();
@@ -327,7 +327,7 @@ public static void deleteAllJobs(Logger logger, Client client) throws Exception
327327
try {
328328
CloseJobAction.Request closeRequest = new CloseJobAction.Request(MetaData.ALL);
329329
closeRequest.setForce(true);
330-
closeRequest.setCloseTimeout(TimeValue.timeValueSeconds(20L));
330+
closeRequest.setCloseTimeout(TimeValue.timeValueSeconds(30L));
331331
CloseJobAction.Response response =
332332
client.execute(CloseJobAction.INSTANCE, closeRequest).get();
333333
assertTrue(response.isClosed());

0 commit comments

Comments
 (0)