-
Type:
Bug
-
Status: Resolved
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: None
-
Fix Version/s: 1.11.0
-
Component/s: Extensions
-
Labels:None
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.
- links to