|
14 | 14 | import org.elasticsearch.common.unit.ByteSizeUnit;
|
15 | 15 | import org.elasticsearch.common.unit.ByteSizeValue;
|
16 | 16 | import org.elasticsearch.common.unit.TimeValue;
|
| 17 | +import org.elasticsearch.persistent.PersistentTasksCustomMetadata; |
17 | 18 | import org.elasticsearch.transport.TransportService;
|
18 | 19 | import org.elasticsearch.xpack.core.ml.MlTasks;
|
19 | 20 | import org.elasticsearch.xpack.core.ml.action.CloseJobAction;
|
|
23 | 24 | import org.elasticsearch.xpack.core.ml.job.config.Job;
|
24 | 25 | import org.elasticsearch.xpack.core.ml.job.config.JobState;
|
25 | 26 | import org.elasticsearch.xpack.core.ml.job.config.JobTaskState;
|
26 |
| -import org.elasticsearch.persistent.PersistentTasksCustomMetadata; |
27 | 27 | import org.elasticsearch.xpack.ml.MachineLearning;
|
28 | 28 | import org.elasticsearch.xpack.ml.support.BaseMlIntegTestCase;
|
29 |
| -import org.apache.lucene.util.LuceneTestCase.AwaitsFix; |
30 | 29 |
|
31 | 30 | public class TooManyJobsIT extends BaseMlIntegTestCase {
|
32 | 31 |
|
33 |
| - @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/54162") |
34 | 32 | public void testCloseFailedJob() throws Exception {
|
35 | 33 | startMlCluster(1, 1);
|
36 | 34 |
|
@@ -76,6 +74,7 @@ public void testLazyNodeValidation() throws Exception {
|
76 | 74 | }
|
77 | 75 | logger.info("Started [{}] nodes", numNodes);
|
78 | 76 | ensureStableCluster(numNodes);
|
| 77 | + ensureTemplatesArePresent(); |
79 | 78 | logger.info("[{}] is [{}]", MachineLearning.MAX_LAZY_ML_NODES.getKey(), maxNumberOfLazyNodes);
|
80 | 79 | // Set our lazy node number
|
81 | 80 | assertTrue(client().admin()
|
@@ -210,6 +209,7 @@ private void startMlCluster(int numNodes, int maxNumberOfWorkersPerNode) throws
|
210 | 209 | }
|
211 | 210 | logger.info("Started [{}] nodes", numNodes);
|
212 | 211 | ensureStableCluster(numNodes);
|
| 212 | + ensureTemplatesArePresent(); |
213 | 213 | }
|
214 | 214 |
|
215 | 215 | private long calculateMaxMlMemory() {
|
|
0 commit comments