|
64 | 64 | import java.util.List; |
65 | 65 | import java.util.Map; |
66 | 66 | import java.util.Optional; |
| 67 | +import java.util.concurrent.TimeUnit; |
67 | 68 | import java.util.concurrent.atomic.AtomicReference; |
68 | 69 | import java.util.stream.Collectors; |
69 | 70 |
|
@@ -189,7 +190,6 @@ public void testMonitoringBulk() throws Exception { |
189 | 190 | * This test waits for the monitoring service to collect monitoring documents and then checks that all expected documents |
190 | 191 | * have been indexed with the expected information. |
191 | 192 | */ |
192 | | - @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/29880") |
193 | 193 | public void testMonitoringService() throws Exception { |
194 | 194 | final boolean createAPMIndex = randomBoolean(); |
195 | 195 | final String indexName = createAPMIndex ? "apm-2017.11.06" : "books"; |
@@ -374,9 +374,6 @@ private void assertClusterStatsMonitoringDoc(final Map<String, Object> document, |
374 | 374 | assertThat(clusterState.remove("cluster_uuid"), notNullValue()); |
375 | 375 | assertThat(clusterState.remove("master_node"), notNullValue()); |
376 | 376 | assertThat(clusterState.remove("nodes"), notNullValue()); |
377 | | - assertThat(clusterState.remove("term"), notNullValue()); |
378 | | - assertThat(clusterState.remove("last_committed_config"), notNullValue()); |
379 | | - assertThat(clusterState.remove("last_accepted_config"), notNullValue()); |
380 | 377 | assertThat(clusterState.keySet(), empty()); |
381 | 378 |
|
382 | 379 | final Map<String, Object> clusterSettings = (Map<String, Object>) source.get("cluster_settings"); |
@@ -612,7 +609,7 @@ public void enableMonitoring() throws Exception { |
612 | 609 | .setSize(0) |
613 | 610 | .get().getHits().getTotalHits().value, |
614 | 611 | greaterThan(0L)); |
615 | | - }); |
| 612 | + }, 30L, TimeUnit.SECONDS); |
616 | 613 | } |
617 | 614 |
|
618 | 615 | /** |
@@ -649,7 +646,7 @@ public void disableMonitoring() throws Exception { |
649 | 646 | } catch (Exception e) { |
650 | 647 | throw new ElasticsearchException("Failed to wait for monitoring exporters to stop:", e); |
651 | 648 | } |
652 | | - }); |
| 649 | + }, 30L, TimeUnit.SECONDS); |
653 | 650 | } |
654 | 651 |
|
655 | 652 | private boolean getMonitoringUsageExportersDefined() throws Exception { |
|
0 commit comments