[
https://issues.apache.org/jira/browse/NIFI-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tamas Palfy reassigned NIFI-7039:
---------------------------------
Assignee: Tamas Palfy
> PublishJMS can fail with ConcurrentModificationException
> --------------------------------------------------------
>
> Key: NIFI-7039
> URL: https://issues.apache.org/jira/browse/NIFI-7039
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Reporter: Tamas Palfy
> Assignee: Tamas Palfy
> Priority: Major
>
> {{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)
