Tamas Palfy created NIFI-7039:
---------------------------------

             Summary: PublishJMS can fail with ConcurrentModificationException
                 Key: NIFI-7039
                 URL: https://issues.apache.org/jira/browse/NIFI-7039
             Project: Apache NiFi
          Issue Type: Improvement
          Components: Extensions
            Reporter: Tamas Palfy


{{PublishJMS}} tries to cleanup flowfile attributes before sending them over 
JMS.

However it does so via iterating over the entries of a Map and removing 
unwanted ones - within the same iteration cycle:

{code:java}
                    for (final Map.Entry<String,String> entry : 
attributesToSend.entrySet()) {
                        if (!entry.getKey().endsWith(".type")){
                            if (entry.getKey().contains("-") || 
entry.getKey().contains(".")) {
                                attributesToSend.remove(entry.getKey());
                            }
                        }
                    }
{code}

This is undetermenistic and should not be done as can lead to 
ConcurrentModificationException.





--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to