Repository: nifi Updated Branches: refs/heads/master a2fb5fc22 -> bc75dd3c1
NIFI-1406 Collecting the number of bytes sent regardless if one or multiple FlowFiles are sent. Reviewed by Tony Kurc ([email protected]). This closes #176 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/bc75dd3c Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/bc75dd3c Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/bc75dd3c Branch: refs/heads/master Commit: bc75dd3c175e48629aa0971c701b3df93433ac9b Parents: a2fb5fc Author: Aldrin Piri <[email protected]> Authored: Sun Jan 17 22:14:17 2016 -0500 Committer: Tony Kurc <[email protected]> Committed: Wed Jan 20 21:08:15 2016 -0500 ---------------------------------------------------------------------- .../org/apache/nifi/processors/standard/PostHTTP.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/bc75dd3c/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PostHTTP.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PostHTTP.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PostHTTP.java index 4aba8fe..2aaf800 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PostHTTP.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PostHTTP.java @@ -549,14 +549,14 @@ public class PostHTTP extends AbstractProcessor { } } - // if we are not sending as flowfile, or if the destination doesn't accept V3 or V2 (streaming) format, - // then only use a single FlowFile - if (!sendAsFlowFile || !destinationAccepts.isFlowFileV3Accepted() && !destinationAccepts.isFlowFileV2Accepted()) { + bytesToSend += flowFile.getSize(); + if (bytesToSend > maxBatchBytes.longValue()) { break; } - bytesToSend += flowFile.getSize(); - if (bytesToSend > maxBatchBytes.longValue()) { + // if we are not sending as flowfile, or if the destination doesn't accept V3 or V2 (streaming) format, + // then only use a single FlowFile + if (!sendAsFlowFile || !destinationAccepts.isFlowFileV3Accepted() && !destinationAccepts.isFlowFileV2Accepted()) { break; } }
