Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
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.
Attachments
Issue Links
- links to