nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Joseph Percivall (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (NIFI-1766) AbstractPutEventProcessor - the sender pool object and sender objects are recreated before and after every call to OnTrigger() respectively.
Date Fri, 17 Jun 2016 00:59:05 GMT

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

Mime
View raw message