[
https://issues.apache.org/jira/browse/NIFI-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joseph Percivall resolved NIFI-1766.
------------------------------------
Resolution: Not A Bug
Reporter verified the mistake was in their test code.
> AbstractPutEventProcessor - the sender pool object and sender objects are
> recreated before and after every call to OnTrigger() respectively.
> --------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: NIFI-1766
> URL: https://issues.apache.org/jira/browse/NIFI-1766
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Affects Versions: 0.6.0
> Reporter: Matt Brown
> Priority: Minor
> Attachments: 0001-NIFI-1766.patch
>
>
> AbstractPutEventProcessor creates the sender pool list object in the
> OnScheduled() method which is annotated with @OnScheduled. This method
> therefore gets called before every OnTrigger() call. The sender pool is
> therefore being recreated for every single FlowFile that is handled by
> OnTrigger(). Is this the correct behaviour? I was expecting the pool to be
> created once for the lifetime of the Processor instance.
> Similarly, the sender objects within the sender pool are being closed down by
> the closeSenders() method which is annotated with @OnStopped. This method
> therefore gets called after each OnTrigger() call has completed. The senders
> are therefore being deleted after every OnTrigger() call (and then recreated
> in the next OnTrigger() call). Is this the intended behaviour? For TCP
> senders, this means that each FlowFIle is sent over a new TCP connection. I
> was expecting all FlowFiles to be sent out over the same TCP connection.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
