[
https://issues.apache.org/jira/browse/NIFI-1436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15115725#comment-15115725
]
ASF GitHub Bot commented on NIFI-1436:
--------------------------------------
Github user bbende commented on the pull request:
https://github.com/apache/nifi/pull/189#issuecomment-174615789
Pushed up a new commit that combines stop() and close() into a single call
for simplicity, basically preventing someone from calling close() without
calling stop().
Added additional checks on the stopped flag in the run method:
* Right after returning from select which should happen during close() when
selector.wakeup() is called and stopped is already true
* While looping over the selected keys in run() so that we don't modify the
keys after being stopped
> 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)
