markap14 commented on code in PR #10912:
URL: https://github.com/apache/nifi/pull/10912#discussion_r2822879836
##########
nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/connectable/ProcessGroupFlowFileActivity.java:
##########
@@ -135,9 +147,18 @@ public FlowFileTransferCounts getTransferCounts() {
totalSentBytes += counts.getSentBytes();
}
- // Aggregate transfer counts from all funnels
- for (final Connectable connectable : group.getFunnels()) {
- final FlowFileTransferCounts counts =
connectable.getFlowFileActivity().getTransferCounts();
+ for (final ProcessGroup childGroup : group.getProcessGroups()) {
Review Comment:
Yes, I intentionally removed Funnels. Should have never had there there.
This is specifically for counting the number of FlowFiles/bytes sent and
received. Funnels never send or receive data, they only move it to the next
queue.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
