[NIFI-7039] PublishJMS can fail with ConcurrentModificationException

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: Extensions
• Assignee: Tamas Palfy
• Reporter: Tamas Palfy
• Created: 17/Jan/20 14:53
• Updated: 02/Apr/20 14:04
• Resolved: 19/Jan/20 16:05

Description

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:

                    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());
                            }
                        }
                    }

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

Issue Links

• links to: GitHub Pull Request #3995