[TEST] Increase timeout for ML internal cluster cleanup (elastic#50142)

Closes elastic#48511
SivagurunathanV · Jan 21, 2020 · 8102a52 · 8102a52
1 parent 67d3cb7
commit 8102a52
Showing 1 changed file with 7 additions and 7 deletions.
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
@@ -313,24 +313,24 @@ public static void deleteAllJobs(Logger logger, Client client) throws Exception
 
         try {
             CloseJobAction.Request closeRequest = new CloseJobAction.Request(MetaData.ALL);
-            closeRequest.setCloseTimeout(TimeValue.timeValueSeconds(30L));
+            // This usually takes a lot less than 90 seconds, but has been observed to be very slow occasionally
+            // in CI and a 90 second timeout will avoid the cost of investigating these intermittent failures.
+            // See https://github.com/elastic/elasticsearch/issues/48511
+            closeRequest.setCloseTimeout(TimeValue.timeValueSeconds(90L));
             logger.info("Closing jobs using [{}]", MetaData.ALL);
-            CloseJobAction.Response response = client.execute(CloseJobAction.INSTANCE, closeRequest)
-                    .get();
+            CloseJobAction.Response response = client.execute(CloseJobAction.INSTANCE, closeRequest).get();
             assertTrue(response.isClosed());
         } catch (Exception e1) {
             try {
                 CloseJobAction.Request closeRequest = new CloseJobAction.Request(MetaData.ALL);
                 closeRequest.setForce(true);
                 closeRequest.setCloseTimeout(TimeValue.timeValueSeconds(30L));
-                CloseJobAction.Response response =
-                        client.execute(CloseJobAction.INSTANCE, closeRequest).get();
+                CloseJobAction.Response response = client.execute(CloseJobAction.INSTANCE, closeRequest).get();
                 assertTrue(response.isClosed());
             } catch (Exception e2) {
                 logger.warn("Force-closing jobs failed.", e2);
             }
-            throw new RuntimeException("Had to resort to force-closing job, something went wrong?",
-                    e1);
+            throw new RuntimeException("Had to resort to force-closing job, something went wrong?", e1);
         }
 
         for (final Job job : jobs.results()) {