[jira] [Commented] (NIFI-9365) Node can fail to offload due to ConcurrentModificationException

["ASF subversion and git services (Jira)" <ji...@apache.org>]

    [ 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 <ex...@apache.org>


> 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)