[TEST] Actually perform the intended close...
Original commit: elastic/x-pack-elasticsearch@1333d785091eb81d8525f87fabecfbfeceac932c
@@ -341,7 +341,7 @@ public class BasicDistributedJobsIT extends BaseMlIntegTestCase {
assertEquals(2, response.getDataCounts().getProcessedRecordCount());
CloseJobAction.Request closeJobRequest = new CloseJobAction.Request("job_id");
- client().execute(CloseJobAction.INSTANCE, closeJobRequest);
+ client().execute(CloseJobAction.INSTANCE, closeJobRequest).actionGet();
assertBusy(() -> {
ClusterState clusterState = client().admin().cluster().prepareState().get().getState();
PersistentTasksCustomMetaData tasks = clusterState.getMetaData().custom(PersistentTasksCustomMetaData.TYPE);
