Github user markap14 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2954#discussion_r219837666
--- Diff:
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/MergeRecord.java
---
@@ -304,13 +336,25 @@ public void onTrigger(final ProcessContext context,
final ProcessSessionFactory
session.commit();
}
+ // If there is no more data queued up, complete any bin that meets
our minimum threshold
+ int completedBins = 0;
+ final QueueSize queueSize = session.getQueueSize();
--- End diff --
@bdesert that's a great catch! I have pushed a new commit that updates the
code like you suggested, to just check the size of the flowFiles list. I also
created NIFI-5626 to address the inconsistency between MockProcessSession and
StandardProcessSession.
---
