From 8a7d27d5eae3b350353eb1bf2e6267b72271a47a Mon Sep 17 00:00:00 2001 From: Keith Massey Date: Fri, 21 Nov 2025 12:41:53 -0600 Subject: [PATCH 1/2] Change DatabaseNodeService error logs to warnings --- .../ingest/geoip/DatabaseNodeService.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) 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 b3038d2fd59fa..7cbfae5fb52b7 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 @@ -371,7 +371,7 @@ void checkDatabases(ProjectState projectState) { try { retrieveAndUpdateDatabase(projectId, name, metadata); } catch (Exception ex) { - logger.error(() -> "failed to retrieve database [" + name + "]", ex); + logger.warn(() -> "failed to retrieve database [" + name + "]", ex); } }); @@ -468,13 +468,13 @@ void retrieveAndUpdateDatabase(ProjectId projectId, String databaseName, GeoIpTa Files.delete(retrievedFile); }, failure -> { - logger.error(() -> "failed to retrieve database [" + databaseName + "]", failure); + logger.warn(() -> "failed to retrieve database [" + databaseName + "]", failure); try { Files.deleteIfExists(databaseTmpFile); Files.deleteIfExists(retrievedFile); } catch (IOException ioe) { ioe.addSuppressed(failure); - logger.error("unable to delete tmp database file after failure", ioe); + logger.warn("unable to delete tmp database file after failure", ioe); } } ); @@ -519,7 +519,7 @@ void updateDatabase(ProjectId projectId, String databaseFileName, String recorde } logger.info("successfully loaded database file [{}]", file.getFileName()); } catch (Exception e) { - logger.error(() -> "failed to update database [" + databaseFileName + "]", e); + logger.warn(() -> "failed to update database [" + databaseFileName + "]", e); } } @@ -533,7 +533,7 @@ void removeStaleEntries(ProjectId projectId, Collection staleEntries) { assert existing != null; existing.shutdown(true); } catch (Exception e) { - logger.error(() -> "failed to clean database [" + staleEntry + "] for project [" + projectId + "]", e); + logger.warn(() -> "failed to clean database [" + staleEntry + "] for project [" + projectId + "]", e); } } } From 49627d2cae0e71af255e38450c61d2ee92618dd1 Mon Sep 17 00:00:00 2001 From: Keith Massey Date: Fri, 21 Nov 2025 12:45:42 -0600 Subject: [PATCH 2/2] Update docs/changelog/138438.yaml --- docs/changelog/138438.yaml | 5 +++++ 1 file changed, 5 insertions(+) create mode 100644 docs/changelog/138438.yaml diff --git a/docs/changelog/138438.yaml b/docs/changelog/138438.yaml new file mode 100644 index 0000000000000..8d3a4309cc3b5 --- /dev/null +++ b/docs/changelog/138438.yaml @@ -0,0 +1,5 @@ +pr: 138438 +summary: Change `DatabaseNodeService` error logs to warnings +area: Ingest Node +type: bug +issues: []