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)