|
16 | 16 | import org.elasticsearch.test.ESIntegTestCase; |
17 | 17 | import org.elasticsearch.xcontent.XContentBuilder; |
18 | 18 | import org.elasticsearch.xcontent.json.JsonXContent; |
19 | | -import org.elasticsearch.xpack.core.ml.MlTasks; |
20 | 19 | import org.elasticsearch.xpack.core.ml.action.CloseJobAction; |
21 | 20 | import org.elasticsearch.xpack.core.ml.action.GetJobsStatsAction; |
22 | 21 | import org.elasticsearch.xpack.core.ml.action.GetTrainedModelsStatsAction; |
|
38 | 37 | import org.elasticsearch.xpack.ml.inference.persistence.TrainedModelDefinitionDoc; |
39 | 38 | import org.elasticsearch.xpack.ml.support.BaseMlIntegTestCase; |
40 | 39 |
|
41 | | -import java.time.Duration; |
42 | | -import java.time.temporal.ChronoUnit; |
43 | 40 | import java.util.List; |
44 | 41 | import java.util.Set; |
45 | 42 |
|
|
59 | 56 | @ESIntegTestCase.ClusterScope(scope = ESIntegTestCase.Scope.TEST, numDataNodes = 0) |
60 | 57 | public class JobsAndModelsIT extends BaseMlIntegTestCase { |
61 | 58 |
|
62 | | - @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/103588") |
63 | 59 | public void testCluster_GivenAnomalyDetectionJobAndTrainedModelDeployment_ShouldNotAllocateBothOnSameNode() throws Exception { |
64 | 60 | // This test starts 2 ML nodes and then starts an anomaly detection job and a |
65 | 61 | // trained model deployment that do not both fit in one node. We then proceed |
@@ -237,8 +233,6 @@ public void testCluster_GivenAnomalyDetectionJobAndTrainedModelDeployment_Should |
237 | 233 | assertThat(jobStats.getNode(), is(not(equalTo(modelStats.getDeploymentStats().getNodeStats().get(0).getNode())))); |
238 | 234 | }); |
239 | 235 |
|
240 | | - assertRecentLastTaskStateChangeTime(MlTasks.jobTaskId(jobId), Duration.of(10, ChronoUnit.SECONDS), null); |
241 | | - |
242 | 236 | // Clean up |
243 | 237 | client().execute(CloseJobAction.INSTANCE, new CloseJobAction.Request(jobId).setForce(true)).actionGet(); |
244 | 238 | client().execute(StopTrainedModelDeploymentAction.INSTANCE, new StopTrainedModelDeploymentAction.Request(model.getModelId())) |
|
0 commit comments