You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by jo...@apache.org on 2017/05/25 02:15:10 UTC
nifi git commit: NIFI-3971: This closes #1854. Fixed bug in
calculating content size that was transferred when cloning a relationship
Repository: nifi
Updated Branches:
refs/heads/master 5aa3baca7 -> eaefec6d8
NIFI-3971: This closes #1854. Fixed bug in calculating content size that was transferred when cloning a relationship
Signed-off-by: joewitt <jo...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/eaefec6d
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/eaefec6d
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/eaefec6d
Branch: refs/heads/master
Commit: eaefec6d81f9dbf0d239776ef465b14109e28d18
Parents: 5aa3bac
Author: Mark Payne <ma...@hotmail.com>
Authored: Wed May 24 15:31:33 2017 -0400
Committer: joewitt <jo...@apache.org>
Committed: Wed May 24 22:14:56 2017 -0400
----------------------------------------------------------------------
.../nifi/controller/repository/StandardProcessSession.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/eaefec6d/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
index 62326a2..d34d8cf 100644
--- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
+++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
@@ -1883,12 +1883,12 @@ public final class StandardProcessSession implements ProcessSession, ProvenanceE
record.setTransferRelationship(relationship);
updateLastQueuedDate(record);
- contentSize += flowFile.getSize() * multiplier;
+ contentSize += flowFile.getSize();
}
if (autoTerminated) {
removedCount += multiplier * flowFiles.size();
- removedBytes += contentSize;
+ removedBytes += multiplier * contentSize;
} else if (!selfRelationship) {
flowFilesOut += multiplier * flowFiles.size();
contentSizeOut += multiplier * contentSize;