Repository: nifi Updated Branches: refs/heads/master 1ddd73655 -> 1f6805f06
NIFI-886 purging old events much more frequently Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/1f6805f0 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/1f6805f0 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/1f6805f0 Branch: refs/heads/master Commit: 1f6805f06d39410c64b47447a36945afbd16229b Parents: 1ddd736 Author: joewitt <[email protected]> Authored: Fri Aug 21 15:40:26 2015 -0400 Committer: joewitt <[email protected]> Committed: Fri Aug 21 15:40:26 2015 -0400 ---------------------------------------------------------------------- .../apache/nifi/provenance/PersistentProvenanceRepository.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/1f6805f0/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/PersistentProvenanceRepository.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/PersistentProvenanceRepository.java b/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/PersistentProvenanceRepository.java index 66f9642..3497e12 100644 --- a/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/PersistentProvenanceRepository.java +++ b/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/PersistentProvenanceRepository.java @@ -108,6 +108,7 @@ public class PersistentProvenanceRepository implements ProvenanceEventRepository public static final String EVENT_CATEGORY = "Provenance Repository"; private static final String FILE_EXTENSION = ".prov"; private static final String TEMP_FILE_SUFFIX = ".prov.part"; + private static final long PURGE_EVENT_MILLISECONDS = 2500L; //Determines the frequency over which the task to delete old events will occur public static final int SERIALIZATION_VERSION = 8; public static final Pattern NUMBER_PATTERN = Pattern.compile("\\d+"); public static final Pattern INDEX_PATTERN = Pattern.compile("index-\\d+"); @@ -265,7 +266,7 @@ public class PersistentProvenanceRepository implements ProvenanceEventRepository eventReporter.reportEvent(Severity.ERROR, EVENT_CATEGORY, "Failed to purge old events from Provenance Repo due to " + e.toString()); } } - }, 1L, 1L, TimeUnit.MINUTES); + }, PURGE_EVENT_MILLISECONDS, PURGE_EVENT_MILLISECONDS, TimeUnit.MILLISECONDS); } firstEventTimestamp = determineFirstEventTimestamp();
