Skip to content

Commit fdbbe3b

Browse files
authored
Re-enable GeoIpDownloaderIT#testStartWithNoDatabases() (#79907)
Relates to #79074
1 parent 28a0ab8 commit fdbbe3b

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

modules/ingest-geoip/src/internalClusterTest/java/org/elasticsearch/ingest/geoip/GeoIpDownloaderIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -352,7 +352,7 @@ public void testUseGeoIpProcessorWithDownloadedDBs() throws Exception {
352352
});
353353
}
354354

355-
@AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/79074")
355+
@TestLogging(value = "org.elasticsearch.ingest.geoip:TRACE", reason = "https://github.com/elastic/elasticsearch/issues/79074")
356356
public void testStartWithNoDatabases() throws Exception {
357357
assumeTrue("only test with fixture to have stable results", ENDPOINT != null);
358358
putPipeline();

modules/ingest-geoip/src/main/java/org/elasticsearch/ingest/geoip/DatabaseNodeService.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -324,10 +324,11 @@ void updateDatabase(String databaseFileName, String recordedMd5, Path file) {
324324
Predicate<GeoIpProcessor.DatabaseUnavailableProcessor> predicate = p -> databaseFileName.equals(p.getDatabaseName());
325325
var ids = ingestService.getPipelineWithProcessorType(GeoIpProcessor.DatabaseUnavailableProcessor.class, predicate);
326326
if (ids.isEmpty() == false) {
327+
LOGGER.debug("pipelines [{}] found to reload", ids);
327328
for (var id : ids) {
328329
try {
329330
ingestService.reloadPipeline(id);
330-
LOGGER.debug(
331+
LOGGER.trace(
331332
"successfully reloaded pipeline [{}] after downloading of database [{}] for the first time",
332333
id,
333334
databaseFileName
@@ -343,6 +344,8 @@ void updateDatabase(String databaseFileName, String recordedMd5, Path file) {
343344
);
344345
}
345346
}
347+
} else {
348+
LOGGER.debug("no pipelines found to reload");
346349
}
347350
}
348351
LOGGER.info("successfully reloaded changed geoip database file [{}]", file);

0 commit comments

Comments
 (0)