diff --git a/paimon-core/src/main/java/org/apache/paimon/table/ExpireChangelogImpl.java b/paimon-core/src/main/java/org/apache/paimon/table/ExpireChangelogImpl.java index 1b42f2339bad..9c7813c35d2d 100644 --- a/paimon-core/src/main/java/org/apache/paimon/table/ExpireChangelogImpl.java +++ b/paimon-core/src/main/java/org/apache/paimon/table/ExpireChangelogImpl.java @@ -152,7 +152,7 @@ public int expireUntil(long earliestId, long endExclusiveId) { Set manifestSkippSet = changelogDeletion.manifestSkippingSet(skippingSnapshots); for (long id = earliestId; id < endExclusiveId; id++) { if (LOG.isDebugEnabled()) { - LOG.debug("Ready to delete changelog files from changelog #" + id); + LOG.debug("Ready to delete changelog files from changelog #{}", id); } Changelog changelog = changelogManager.longLivedChangelog(id); Predicate skipper; @@ -218,13 +218,13 @@ public void expireAll() { Set manifestSkippSet = changelogDeletion.manifestSkippingSet(skippingSnapshots); for (long id = earliestChangelogId; id <= latestChangelogId; id++) { - LOG.info("Ready to delete changelog files from changelog #" + id); + LOG.info("Ready to delete changelog files from changelog #{}", id); Changelog changelog; try { changelog = changelogManager.tryGetChangelog(id); } catch (FileNotFoundException e) { - LOG.info("fail to get changelog #" + id); + LOG.info("fail to get changelog #{}", id); continue; } Predicate skipper; diff --git a/paimon-core/src/main/java/org/apache/paimon/table/ExpireSnapshotsImpl.java b/paimon-core/src/main/java/org/apache/paimon/table/ExpireSnapshotsImpl.java index 01c7e74966ce..5fcc40a7fdde 100644 --- a/paimon-core/src/main/java/org/apache/paimon/table/ExpireSnapshotsImpl.java +++ b/paimon-core/src/main/java/org/apache/paimon/table/ExpireSnapshotsImpl.java @@ -170,7 +170,7 @@ public int expireUntil(long earliestId, long endExclusiveId) { // id should be (beginInclusiveId, endExclusiveId] for (long id = beginInclusiveId + 1; id <= endExclusiveId; id++) { if (LOG.isDebugEnabled()) { - LOG.debug("Ready to delete merge tree files not used by snapshot #" + id); + LOG.debug("Ready to delete merge tree files not used by snapshot #{}", id); } Snapshot snapshot; try { @@ -199,7 +199,7 @@ public int expireUntil(long earliestId, long endExclusiveId) { if (!expireConfig.isChangelogDecoupled()) { for (long id = beginInclusiveId; id < endExclusiveId; id++) { if (LOG.isDebugEnabled()) { - LOG.debug("Ready to delete changelog files from snapshot #" + id); + LOG.debug("Ready to delete changelog files from snapshot #{}", id); } Snapshot snapshot; try { @@ -239,7 +239,7 @@ public int expireUntil(long earliestId, long endExclusiveId) { if (skippingSet != null) { for (long id = beginInclusiveId; id < endExclusiveId; id++) { if (LOG.isDebugEnabled()) { - LOG.debug("Ready to delete manifests in snapshot #" + id); + LOG.debug("Ready to delete manifests in snapshot #{}", id); } Snapshot snapshot;