NIFI-14110 Enhance tests to ensure FlowFiles are rejected once size l…

…imit was reached
apache · Dec 28, 2024 · 4da4d0b · 4da4d0b
1 parent 3715edb
commit 4da4d0b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/processor/util/FlowFileFilters.java b/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/processor/util/FlowFileFilters.java
@@ -59,4 +59,5 @@ public FlowFileFilterResult filter(final FlowFile flowFile) {
             }
         };
     }
+
 }
diff --git a/...-commons/nifi-utils/src/test/java/org/apache/nifi/processor/util/FlowFileFiltersTest.java b/...-commons/nifi-utils/src/test/java/org/apache/nifi/processor/util/FlowFileFiltersTest.java
@@ -71,7 +71,8 @@ void rejectsFlowFilesOnceMaxSizeWasReached() {
             assertEquals(ACCEPT_AND_CONTINUE, filter.filter(emptyFlowFile()));
 
             assertEquals(REJECT_AND_TERMINATE, filter.filter(flowFileOfSize(1)));
-
+            // empty content FlowFiles are no longer accepted
+            assertEquals(REJECT_AND_TERMINATE, filter.filter(emptyFlowFile()));
         }
 
         private FlowFile emptyFlowFile() {
-Original file line number
+Diff line change
@@ Expand Up / @@ -59,4 +59,5 @@ public FlowFileFilterResult filter(final FlowFile flowFile) { @@
                 }
             };
         }
     }