NIFI-730: Updated details of Provenance Event for when a queue is emptied
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/b8dbd101 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/b8dbd101 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/b8dbd101 Branch: refs/heads/NIFI-274 Commit: b8dbd1018cf0b2d09bf7371849cf8b588d5f3f7c Parents: 39a050d Author: Mark Payne <marka...@hotmail.com> Authored: Fri Oct 16 08:53:40 2015 -0400 Committer: Mark Payne <marka...@hotmail.com> Committed: Fri Oct 16 08:53:40 2015 -0400 ---------------------------------------------------------------------- .../java/org/apache/nifi/controller/StandardFlowFileQueue.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/b8dbd101/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowFileQueue.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowFileQueue.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowFileQueue.java index 6e42f55..a9e80b0 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowFileQueue.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowFileQueue.java @@ -1095,7 +1095,7 @@ public final class StandardFlowFileQueue implements FlowFileQueue { builder.setComponentId(getIdentifier()); builder.setComponentType("Connection"); builder.setAttributes(flowFile.getAttributes(), Collections.<String, String> emptyMap()); - builder.setDetails("Manually dropped by " + requestor); + builder.setDetails("FlowFile Queue emptied by " + requestor); builder.setSourceQueueIdentifier(getIdentifier()); final ContentClaim contentClaim = flowFile.getContentClaim();
