[
https://issues.apache.org/jira/browse/NIFI-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15115567#comment-15115567
]
Joseph Witt commented on NIFI-1436:
-----------------------------------
the concurrent mod it appears would happen during run channel selector loop and
close selector channel loop. So lets just mark the whole thing as closed the
moment closed is entered and check in the run loop for this. Make sure to mark
that boolean as volatile (or use atomic boolean). And be done with it. Other
than the atomic/volatile handling this retains the relatively lock-free
approach.
> Intermittent Failure of TestListenSyslog
> ----------------------------------------
>
> Key: NIFI-1436
> URL: https://issues.apache.org/jira/browse/NIFI-1436
> Project: Apache NiFi
> Issue Type: Bug
> Affects Versions: 0.5.0
> Reporter: Bryan Bende
> Assignee: Bryan Bende
> Priority: Minor
> Fix For: 0.5.0
>
>
> Tests run: 8, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 2.165 sec <<<
> FAILURE! - in org.apache.nifi.processors.standard.TestListenSyslog
> testTCPSingleConnection(org.apache.nifi.processors.standard.TestListenSyslog)
> Time elapsed: 0.716 sec <<< ERROR!
> java.util.ConcurrentModificationException: null
> at java.util.HashMap$HashIterator.nextNode(HashMap.java:1429)
> at java.util.HashMap$KeyIterator.next(HashMap.java:1453)
> at
> java.util.Collections$UnmodifiableCollection$1.next(Collections.java:1042)
> at
> org.apache.nifi.processor.util.listen.dispatcher.SocketChannelDispatcher.close(SocketChannelDispatcher.java:219)
> at
> org.apache.nifi.processors.standard.ListenSyslog.onUnscheduled(ListenSyslog.java:313)
> at
> org.apache.nifi.processors.standard.TestListenSyslog.testTCPSingleConnection(TestListenSyslog.java:166)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
