[
https://issues.apache.org/jira/browse/NIFI-9365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441241#comment-17441241
]
ASF subversion and git services commented on NIFI-9365:
-------------------------------------------------------
Commit 119ba17bf105f2c057aa5d8f1546867401200856 in nifi's branch
refs/heads/main from Mark Payne
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=119ba17 ]
NIFI-9365: Changed HashMap to ConcurrentHashMap in StandardProcessorNode for
activeThreads
- Methods without the synchronized keyword, such as terminate(), iterate over
activeThreads
This closes #5509
Signed-off-by: David Handermann <[email protected]>
> Node can fail to offload due to ConcurrentModificationException
> ---------------------------------------------------------------
>
> Key: NIFI-9365
> URL: https://issues.apache.org/jira/browse/NIFI-9365
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Reporter: Mark Payne
> Assignee: Mark Payne
> Priority: Major
> Time Spent: 40m
> Remaining Estimate: 0h
>
> I created a System Test that create a cluster, add some processors to the
> flow, and run the flow. Then disconnect one of the nodes and offload it. When
> successful, reconnect node, destroy flow, and start over. Repeat for several
> iterations.
> Intention here was to ensure that we successfully complete offloading after
> trying many times. After several iterations, I encountered a
> ConcurrentModificationException in StandardProcessorNode#getActiveThreads.
> This caused the node not to complete its offloading.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
