You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2015/11/02 20:32:43 UTC
[19/30] nifi git commit: NIFI-730: Set current queue size on drop
flowfile request immediately when creating request
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 <ma...@hotmail.com>
Authored: Wed Oct 14 13:48:59 2015 -0400
Committer: Mark Payne <ma...@hotmail.com>
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() {