diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/repository/TestStandardProcessSession.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/repository/TestStandardProcessSession.java index d549a00d11..644018fd15 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/repository/TestStandardProcessSession.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/repository/TestStandardProcessSession.java @@ -1105,6 +1105,20 @@ public class TestStandardProcessSession { assertEquals(ProvenanceEventType.CONTENT_MODIFIED, event.getEventType()); } + @Test + public void testGetWithCount() { + for (int i = 0; i < 8; i++) { + final FlowFileRecord flowFile = new StandardFlowFileRecord.Builder() + .id(i) + .addAttribute("uuid", "000000000000-0000-0000-0000-0000000" + i) + .build(); + this.flowFileQueue.put(flowFile); + } + + final List flowFiles = session.get(7); + assertEquals(7, flowFiles.size()); + } + @Test public void testAttributesModifiedEmitted() throws IOException { final FlowFileRecord flowFile = new StandardFlowFileRecord.Builder()