NIFI-730: Set current queue size on drop flowfile request immediately when creating request
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/98a04eec Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/98a04eec Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/98a04eec Branch: refs/heads/master Commit: 98a04eec741d5ed72405c6549970de5f1281239e Parents: cad0e7c Author: Mark Payne <[email protected]> Authored: Wed Oct 14 13:48:59 2015 -0400 Committer: Mark Payne <[email protected]> Committed: Wed Oct 14 13:48:59 2015 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/nifi/controller/StandardFlowFileQueue.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/98a04eec/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 062c424..b0c31e7 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 @@ -938,6 +938,7 @@ public final class StandardFlowFileQueue implements FlowFileQueue { } final DropFlowFileRequest dropRequest = new DropFlowFileRequest(requestIdentifier); + dropRequest.setCurrentSize(size()); final Thread t = new Thread(new Runnable() { @Override public void run() {
