From c641da163800f9350dafd93071bf52cbb85d979c Mon Sep 17 00:00:00 2001 From: Keith Massey Date: Mon, 24 Nov 2025 09:50:39 -0600 Subject: [PATCH] Change DatabaseNodeService error logs to warnings (#138438) --- docs/changelog/138438.yaml | 5 +++++ .../ingest/geoip/DatabaseNodeService.java | 10 +++++----- 2 files changed, 10 insertions(+), 5 deletions(-) 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: [] 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); } } }