diff --git a/x-pack/plugin/monitoring/src/test/java/org/elasticsearch/xpack/monitoring/integration/MonitoringIT.java b/x-pack/plugin/monitoring/src/test/java/org/elasticsearch/xpack/monitoring/integration/MonitoringIT.java index f5ed570acb51f..09127bdda84e4 100644 --- a/x-pack/plugin/monitoring/src/test/java/org/elasticsearch/xpack/monitoring/integration/MonitoringIT.java +++ b/x-pack/plugin/monitoring/src/test/java/org/elasticsearch/xpack/monitoring/integration/MonitoringIT.java @@ -64,6 +64,7 @@ import java.util.List; import java.util.Map; import java.util.Optional; +import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicReference; import java.util.stream.Collectors; @@ -189,7 +190,6 @@ public void testMonitoringBulk() throws Exception { * This test waits for the monitoring service to collect monitoring documents and then checks that all expected documents * have been indexed with the expected information. */ - @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/29880") public void testMonitoringService() throws Exception { final boolean createAPMIndex = randomBoolean(); final String indexName = createAPMIndex ? "apm-2017.11.06" : "books"; @@ -374,9 +374,6 @@ private void assertClusterStatsMonitoringDoc(final Map document, assertThat(clusterState.remove("cluster_uuid"), notNullValue()); assertThat(clusterState.remove("master_node"), notNullValue()); assertThat(clusterState.remove("nodes"), notNullValue()); - assertThat(clusterState.remove("term"), notNullValue()); - assertThat(clusterState.remove("last_committed_config"), notNullValue()); - assertThat(clusterState.remove("last_accepted_config"), notNullValue()); assertThat(clusterState.keySet(), empty()); final Map clusterSettings = (Map) source.get("cluster_settings"); @@ -612,7 +609,7 @@ public void enableMonitoring() throws Exception { .setSize(0) .get().getHits().getTotalHits().value, greaterThan(0L)); - }); + }, 30L, TimeUnit.SECONDS); } /** @@ -649,7 +646,7 @@ public void disableMonitoring() throws Exception { } catch (Exception e) { throw new ElasticsearchException("Failed to wait for monitoring exporters to stop:", e); } - }); + }, 30L, TimeUnit.SECONDS); } private boolean getMonitoringUsageExportersDefined() throws Exception {