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 62326a242a..d34d8cf3f1 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;