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 2016/01/21 15:32:41 UTC
[19/23] nifi git commit: NIFI-1406 Collecting the number of bytes
sent regardless if one or multiple FlowFiles are sent.
NIFI-1406 Collecting the number of bytes sent regardless if one or multiple FlowFiles are sent.
Reviewed by Tony Kurc (tkurc@apache.org). 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/NIFI-259
Commit: bc75dd3c175e48629aa0971c701b3df93433ac9b
Parents: a2fb5fc
Author: Aldrin Piri <al...@apache.org>
Authored: Sun Jan 17 22:14:17 2016 -0500
Committer: Tony Kurc <tr...@gmail.com>
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;
}
}