Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down Expand Up @@ -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";
Expand Down Expand Up @@ -374,9 +374,6 @@ private void assertClusterStatsMonitoringDoc(final Map<String, Object> document,
assertThat(clusterState.remove("cluster_uuid"), notNullValue());
assertThat(clusterState.remove("master_node"), notNullValue());
assertThat(clusterState.remove("nodes"), notNullValue());
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Curious to why we are removing these assertions ?

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think it's been added for Zen 2 but removed afterwards, but not noticed since the test was muted.

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<String, Object> clusterSettings = (Map<String, Object>) source.get("cluster_settings");
Expand Down Expand Up @@ -612,7 +609,7 @@ public void enableMonitoring() throws Exception {
.setSize(0)
.get().getHits().getTotalHits().value,
greaterThan(0L));
});
}, 30L, TimeUnit.SECONDS);
}

/**
Expand Down Expand Up @@ -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 {
Expand Down