diff --git a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/pom.xml b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/pom.xml index bb7feecbbf6f..3441edf1bb4a 100644 --- a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/pom.xml +++ b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/pom.xml @@ -51,5 +51,9 @@ lucene-backward-codecs runtime + + org.apache.commons + commons-lang3 + diff --git a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/store/WriteAheadStorePartition.java b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/store/WriteAheadStorePartition.java index 1ccc25beb289..0e2a2d1c7a98 100644 --- a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/store/WriteAheadStorePartition.java +++ b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/store/WriteAheadStorePartition.java @@ -17,6 +17,7 @@ package org.apache.nifi.provenance.store; +import org.apache.commons.lang3.time.DurationFormatUtils; import org.apache.nifi.events.EventReporter; import org.apache.nifi.provenance.ProvenanceEventRecord; import org.apache.nifi.provenance.RepositoryConfiguration; @@ -498,10 +499,12 @@ public void purgeOldEvents(final long olderThan, final TimeUnit unit) { .filter(this::delete) .collect(Collectors.toList()); + String thresholdWords = DurationFormatUtils.formatDurationWords(olderThan, true, true); + if (removed.isEmpty()) { - logger.debug("No Provenance Event files that exceed time-based threshold of {} {}", olderThan, unit); + logger.debug("No Provenance Event files that exceed time-based threshold of {}", thresholdWords); } else { - logger.info("Purged {} Provenance Event files from Provenance Repository because the events were older than {} {}: {}", removed.size(), olderThan, unit, removed); + logger.info("Purged {} Provenance Event files from Provenance Repository because the events were older than {} : {}", removed.size(), thresholdWords, removed); } }