nifi-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dan young <danoyo...@gmail.com>
Subject Re: Nifi 1.4: problem with QueryRecord Precessor
Date Wed, 04 Oct 2017 15:19:30 GMT
This is the error we're seeing:

[image: Screen Shot 2017-10-04 at 9.17.47 AM.png]

ERROR [Timer-Driven Process Thread-4]
o.a.nifi.processors.standard.QueryRecord
QueryRecord[id=e4fdf4c7-015e-1000-61c8-d7bf0df1f41c]
QueryRecord[id=e4fdf4c7-015e-1000-61c8-d7bf0df1f41c] failed to process due
to java.lang.IllegalStateException:
StandardFlowFileRecord[uuid=7a2ba046-9fca-497b-9c4e-d2bd1c323169,claim=StandardContentClaim
[resourceClaim=StandardResourceClaim[id=1507085819128-1, container=default,
section=1], offset=797360, length=398680],offset=0,name=a.csv,size=398680]
already in use for an active callback or an InputStream created by
ProcessSession.read(FlowFile) has not been closed; rolling back session: {}

I'm testing out a basic flow, see attached screenshot.





On Wed, Oct 4, 2017 at 8:55 AM Mark Payne <markap14@hotmail.com> wrote:

> Dan, Uwe,
>
> This is something that I will be looking into shortly. It is a known issue
> that exists in both 1.3
> and 1.4. This occurs whenever there is some other sort of failure, when
> the processor attempts
> to route the FlowFile to 'failure'. This occurs most often when there is a
> problem obtaining the
> schema for the Record. Can you check your logs and see what other error
> may be present
> in the logs?
>
> Thanks
> -Mark
>
>
> On Oct 4, 2017, at 10:39 AM, dan young <danoyoung@gmail.com> wrote:
>
> It might be...maybe others can share experience with 1.4...
>
> On Wed, Oct 4, 2017, 8:37 AM Uwe Geercken <uwe.geercken@web.de> wrote:
>
>> thanks Dano.
>>
>> Any other comments? Is this a bug in 1.4 then?
>>
>> Rgds,
>>
>> Uwe
>>
>> *Gesendet:* Mittwoch, 04. Oktober 2017 um 16:33 Uhr
>> *Von:* "dan young" <danoyoung@gmail.com>
>> *An:* nifi <users@nifi.apache.org>
>> *Betreff:* Re: Nifi 1.4: problem with QueryRecord Precessor
>>
>> We're seeing the same thing. Works fine in 1.3
>>
>> Dano
>>
>> On Wed, Oct 4, 2017, 8:13 AM Uwe Geercken <uwe.geercken@web.de> wrote:
>>
>>> Hello,
>>>
>>> I have created a flow: GetFile >> QueryRecord >> Putfile. GetFile
reads
>>> an avro file. QueryRecord has one property/sql and the result is routed to
>>> PutFile.
>>>
>>> When I run the processor, I get following error:
>>>
>>> failed to process session due to java.lang.IllegalStateException
>>> ....
>>> <filename here> already in use or an active callback or an inputstream
>>> created by ProcessSession.read(FlowFile) has not been closed.
>>> ....
>>>
>>> Can somebody help?
>>>
>>> Rgds,
>>>
>>> Uwe
>>>
>>
>

Mime
View raw message