[
https://issues.apache.org/jira/browse/NIFI-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
n h updated NIFI-3475:
----------------------
Description:
During development of a custom processor (that use FlowFileFilter to get
flowfiles in) we meet some inconsistancy in queues.
I connect a GenerateFlowFile to custom-processor and start both. Then I stoped
both. The connection shows a few flowfiles in the queue (due to filtering) but
I could not delete them until I gracefully restart the Nifi server. I reroute
the connection to a funnel and then that funnel to another funnel to build a
pipe. flowfiles in the queue were not transfered to 2nd connection. Also they
do not expire. There must be some inconsistancy in queue functionality or
presentation that shows non-empty queue state but flowfiles nor could be
deleted neighther expire or transferred.
(If it helps, there is a bug in OnTrigger code of my processor that produce
NullPointerException during the test but my question is not about this bug).
was:
During development a custom processor (that use FlowFileFilter to get flowfiles
in) we meet some inconsistancy in queues.
I connect a GenerateFlowFile to custom-processor and start both. Then I stoped
both. The connection shows a few flowfiles in the queue (due to filtering) but
I could not delete them until I gracefully restart the Nifi server. I reroute
the connection to a funnel and then that funnel to another funnel to build a
pipe. flowfiles in the queue were not transfered to 2nd connection. Also they
do not expire. There must be some inconsistancy in queue functionality or
presentation that shows non-empty queue state but flowfiles nor could be
deleted neighther expire or transferred.
(If it helps, there is a bug in OnTrigger code of my processor that produce
NullPointerException during the test but my question is not about this bug).
> Inconsistancy in queue state. Can not empty a queue.
> ----------------------------------------------------
>
> Key: NIFI-3475
> URL: https://issues.apache.org/jira/browse/NIFI-3475
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Affects Versions: 1.1.0
> Reporter: n h
>
> During development of a custom processor (that use FlowFileFilter to get
> flowfiles in) we meet some inconsistancy in queues.
> I connect a GenerateFlowFile to custom-processor and start both. Then I
> stoped both. The connection shows a few flowfiles in the queue (due to
> filtering) but I could not delete them until I gracefully restart the Nifi
> server. I reroute the connection to a funnel and then that funnel to another
> funnel to build a pipe. flowfiles in the queue were not transfered to 2nd
> connection. Also they do not expire. There must be some inconsistancy in
> queue functionality or presentation that shows non-empty queue state but
> flowfiles nor could be deleted neighther expire or transferred.
> (If it helps, there is a bug in OnTrigger code of my processor that produce
> NullPointerException during the test but my question is not about this bug).
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
