[ 
https://issues.apache.org/jira/browse/NIFI-1237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Bryan Bende updated NIFI-1237:
------------------------------
    Attachment: NIFI-1237.patch

I was able to reproduce this by creating another test that executed 
testBatching() a few hundred times in a loop. 

The batching test was sending 20 messages and the processor has an internal 
queue with capacity 10. Since we are sending all messages before triggering the 
processor, the queue will fill up and the 10 other messages would need to be 
held in the socket buffer.

The attached patch reduces it to 5 messages which is still sufficient for 
testing batching and avoids dealing with the queue being full. Ran this several 
thousand times in a loop and did not fail.

> TestListenSyslog has a race condition?
> --------------------------------------
>
>                 Key: NIFI-1237
>                 URL: https://issues.apache.org/jira/browse/NIFI-1237
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Extensions
>            Reporter: Joseph Witt
>            Assignee: Bryan Bende
>             Fix For: 0.4.0
>
>         Attachments: NIFI-1237.patch
>
>
> causes build to fail at times
>   TestListenSyslog.testBatching:254 expected:<20> but was:<10>



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to