diff --git a/modules/ingest-geoip/src/internalClusterTest/java/org/elasticsearch/ingest/geoip/GeoIpDownloaderIT.java b/modules/ingest-geoip/src/internalClusterTest/java/org/elasticsearch/ingest/geoip/GeoIpDownloaderIT.java index 1e285d6324785..682d18ccc6317 100644 --- a/modules/ingest-geoip/src/internalClusterTest/java/org/elasticsearch/ingest/geoip/GeoIpDownloaderIT.java +++ b/modules/ingest-geoip/src/internalClusterTest/java/org/elasticsearch/ingest/geoip/GeoIpDownloaderIT.java @@ -352,7 +352,7 @@ public void testUseGeoIpProcessorWithDownloadedDBs() throws Exception { }); } - @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/79074") + @TestLogging(value = "org.elasticsearch.ingest.geoip:TRACE", reason = "https://github.com/elastic/elasticsearch/issues/79074") public void testStartWithNoDatabases() throws Exception { assumeTrue("only test with fixture to have stable results", ENDPOINT != null); putPipeline(); diff --git a/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/DatabaseNodeService.java b/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/DatabaseNodeService.java index 87053f176da7c..36240070f3a98 100644 --- a/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/DatabaseNodeService.java +++ b/modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/DatabaseNodeService.java @@ -324,10 +324,11 @@ void updateDatabase(String databaseFileName, String recordedMd5, Path file) { Predicate predicate = p -> databaseFileName.equals(p.getDatabaseName()); var ids = ingestService.getPipelineWithProcessorType(GeoIpProcessor.DatabaseUnavailableProcessor.class, predicate); if (ids.isEmpty() == false) { + LOGGER.debug("pipelines [{}] found to reload", ids); for (var id : ids) { try { ingestService.reloadPipeline(id); - LOGGER.debug( + LOGGER.trace( "successfully reloaded pipeline [{}] after downloading of database [{}] for the first time", id, databaseFileName @@ -343,6 +344,8 @@ void updateDatabase(String databaseFileName, String recordedMd5, Path file) { ); } } + } else { + LOGGER.debug("no pipelines found to reload"); } } LOGGER.info("successfully reloaded changed geoip database file [{}]", file);