diff --git a/modules/ingest-geoip/src/internalClusterTest/java/org/elasticsearch/ingest/geoip/EnterpriseGeoIpDownloaderIT.java b/modules/ingest-geoip/src/internalClusterTest/java/org/elasticsearch/ingest/geoip/EnterpriseGeoIpDownloaderIT.java index ad1fce0ca689a..4cee408d5fab8 100644 --- a/modules/ingest-geoip/src/internalClusterTest/java/org/elasticsearch/ingest/geoip/EnterpriseGeoIpDownloaderIT.java +++ b/modules/ingest-geoip/src/internalClusterTest/java/org/elasticsearch/ingest/geoip/EnterpriseGeoIpDownloaderIT.java @@ -35,6 +35,7 @@ import org.elasticsearch.reindex.ReindexPlugin; import org.elasticsearch.rest.RestStatus; import org.elasticsearch.test.ESIntegTestCase; +import org.elasticsearch.test.junit.annotations.TestLogging; import org.elasticsearch.transport.RemoteTransportException; import org.elasticsearch.xcontent.XContentType; import org.junit.ClassRule; @@ -87,6 +88,10 @@ protected Collection> nodePlugins() { } @SuppressWarnings("unchecked") + @TestLogging( + reason = "understanding why ipinfo asn database sometimes is not loaded", + value = "org.elasticsearch.ingest.geoip.DatabaseNodeService:TRACE" + ) public void testEnterpriseDownloaderTask() throws Exception { /* * This test starts the enterprise geoip downloader task, and creates a database configuration. Then it creates an ingest @@ -121,17 +126,17 @@ public void testEnterpriseDownloaderTask() throws Exception { assertNotNull(returnedSource); Object targetFieldValue = returnedSource.get(targetField); assertNotNull(targetFieldValue); - assertThat(((Map) targetFieldValue).get("organization_name"), equalTo("Bredband2 AB")); + assertThat(((Map) targetFieldValue).get("city_name"), equalTo("Linköping")); }); assertBusy(() -> { logger.info("Ingesting another test document"); - String documentId = ingestDocument(indexName, iplocationPipelineName, sourceField, "12.10.66.1"); + String documentId = ingestDocument(indexName, iplocationPipelineName, sourceField, "103.134.48.0"); GetResponse getResponse = client().get(new GetRequest(indexName, documentId)).actionGet(); Map returnedSource = getResponse.getSource(); assertNotNull(returnedSource); Object targetFieldValue = returnedSource.get(targetField); assertNotNull(targetFieldValue); - assertThat(((Map) targetFieldValue).get("organization_name"), equalTo("OAKLAWN JOCKEY CLUB, INC.")); + assertThat(((Map) targetFieldValue).get("organization_name"), equalTo("PT Nevigate Telekomunikasi Indonesia")); }); } diff --git a/muted-tests.yml b/muted-tests.yml index da6fdd933990d..874f8554c691d 100644 --- a/muted-tests.yml +++ b/muted-tests.yml @@ -86,9 +86,6 @@ tests: - class: org.elasticsearch.xpack.apmdata.APMYamlTestSuiteIT method: test {yaml=/10_apm/Test template reinstallation} issue: https://github.com/elastic/elasticsearch/issues/116445 -- class: org.elasticsearch.ingest.geoip.EnterpriseGeoIpDownloaderIT - method: testEnterpriseDownloaderTask - issue: https://github.com/elastic/elasticsearch/issues/115163 - class: org.elasticsearch.versioning.ConcurrentSeqNoVersioningIT method: testSeqNoCASLinearizability issue: https://github.com/elastic/elasticsearch/issues/117249