[nifi] branch main updated: NIFI-8720: Ensure that when we use Expression Language for Records Per Split property of SplitRecord, we treat the result as a value of 1 if it's less than 1.

[mattyb149]

This is an automated email from the ASF dual-hosted git repository.

mattyb149 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new 6fc9f33  NIFI-8720: Ensure that when we use Expression Language for 
Records Per Split property of SplitRecord, we treat the result as a value of 1 
if it's less than 1.
6fc9f33 is described below

commit 6fc9f33ba23066afca1f33497829cdc35e3b6d5b
Author: Mark Payne <marka...@hotmail.com>
AuthorDate: Mon Jun 21 10:38:13 2021 -0400

    NIFI-8720: Ensure that when we use Expression Language for Records Per 
Split property of SplitRecord, we treat the result as a value of 1 if it's less 
than 1.
    
    Signed-off-by: Matthew Burgess <mattyb...@apache.org>
    
    This closes #5171
---
 .../src/main/java/org/apache/nifi/processors/standard/SplitRecord.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitRecord.java
 
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitRecord.java
index b237a0b..8d67d3c 100644
--- 
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitRecord.java
+++ 
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitRecord.java
@@ -144,7 +144,7 @@ public class SplitRecord extends AbstractProcessor {
         final RecordReaderFactory readerFactory = 
context.getProperty(RECORD_READER).asControllerService(RecordReaderFactory.class);
         final RecordSetWriterFactory writerFactory = 
context.getProperty(RECORD_WRITER).asControllerService(RecordSetWriterFactory.class);
 
-        final int maxRecords = 
context.getProperty(RECORDS_PER_SPLIT).evaluateAttributeExpressions(original).asInteger();
+        final int maxRecords = Math.max(1, 
context.getProperty(RECORDS_PER_SPLIT).evaluateAttributeExpressions(original).asInteger());
 
         final List<FlowFile> splits = new ArrayList<>();
         final Map<String, String> originalAttributes = 
original.getAttributes();