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 <[email protected]> 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 <[email protected]> Authored: Wed May 24 15:31:33 2017 -0400 Committer: joewitt <[email protected]> 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;
