From fd6bd88ba8b9ec62f7743d6c8e215fbd312d76cd Mon Sep 17 00:00:00 2001 From: Hamza Jugon Date: Wed, 27 Nov 2024 17:01:17 +0000 Subject: [PATCH] Update logging in ExpiredMetadataHandler --- .../cleanup/handler/ExpiredMetadataHandler.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/beekeeper-metadata-cleanup/src/main/java/com/expediagroup/beekeeper/metadata/cleanup/handler/ExpiredMetadataHandler.java b/beekeeper-metadata-cleanup/src/main/java/com/expediagroup/beekeeper/metadata/cleanup/handler/ExpiredMetadataHandler.java index f4d78835..69238ec0 100644 --- a/beekeeper-metadata-cleanup/src/main/java/com/expediagroup/beekeeper/metadata/cleanup/handler/ExpiredMetadataHandler.java +++ b/beekeeper-metadata-cleanup/src/main/java/com/expediagroup/beekeeper/metadata/cleanup/handler/ExpiredMetadataHandler.java @@ -80,16 +80,16 @@ public void cleanupMetadata(HousekeepingMetadata housekeepingMetadata, LocalDate } } catch (BeekeeperIcebergException e) { updateAttemptsAndStatus(housekeepingMetadata, SKIPPED); - log.warn("Table \"{}.{}\" is skipped because it is iceberg or could not be identified.", + String logMessage = String.format("Table \"%s.%s\" is skipped because it is iceberg or could not be identified.", housekeepingMetadata.getDatabaseName(), housekeepingMetadata.getTableName()); - log.debug("Table \"{}.{}\" is skipped because it is iceberg or could not be identified.", - housekeepingMetadata.getDatabaseName(), housekeepingMetadata.getTableName(), e); + log.warn(logMessage); + log.debug(logMessage, e); } catch (Exception e) { updateAttemptsAndStatus(housekeepingMetadata, FAILED); - log.warn("Unexpected exception when deleting metadata for table \"{}.{}\".", + String logMessage = String.format("Unexpected exception when deleting metadata for table \"%s.%s\".", housekeepingMetadata.getDatabaseName(), housekeepingMetadata.getTableName()); - log.debug("Unexpected exception when deleting metadata for table \"{}.{}\".", - housekeepingMetadata.getDatabaseName(), housekeepingMetadata.getTableName(), e); + log.warn(logMessage); + log.debug(logMessage, e); } }