[nifi] branch main updated: NIFI-10744 Changed HashSet to LinkedHashSet in SegmentContent for deterministic handling

[exceptionfactory]

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

exceptionfactory 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 2d70bfb380 NIFI-10744 Changed HashSet to LinkedHashSet in 
SegmentContent for deterministic handling
2d70bfb380 is described below

commit 2d70bfb3804c508a0972695407e4e3e6ba22fbcc
Author: sopan98 <phaltankarso...@gmail.com>
AuthorDate: Mon Nov 21 23:30:31 2022 -0500

    NIFI-10744 Changed HashSet to LinkedHashSet in SegmentContent for 
deterministic handling
    
    This closes #6700
    
    Signed-off-by: David Handermann <exceptionfact...@apache.org>
---
 .../main/java/org/apache/nifi/processors/standard/SegmentContent.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SegmentContent.java
 
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SegmentContent.java
index 1fc1feb69a..d29bff812d 100644
--- 
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SegmentContent.java
+++ 
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SegmentContent.java
@@ -20,6 +20,7 @@ import java.util.ArrayList;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.HashSet;
+import java.util.LinkedHashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
@@ -170,7 +171,7 @@ public class SegmentContent extends AbstractProcessor {
         segmentAttributes.put(FRAGMENT_ID, segmentId);
         segmentAttributes.put(FRAGMENT_COUNT, String.valueOf(totalSegments));
 
-        final Set<FlowFile> segmentSet = new HashSet<>();
+        final Set<FlowFile> segmentSet = new LinkedHashSet<>();
         for (int i = 1; i <= totalSegments; i++) {
             final long segmentOffset = segmentSize * (i - 1);
             FlowFile segment = session.clone(flowFile, segmentOffset, 
Math.min(segmentSize, flowFile.getSize() - segmentOffset));