Zhang Haoran created NIFI-8744:
----------------------------------

             Summary: FlowFile queue Prioritizers will not work when queued 
count exceeds nifi.queue.swap.threshold
                 Key: NIFI-8744
                 URL: https://issues.apache.org/jira/browse/NIFI-8744
             Project: Apache NiFi
          Issue Type: Bug
          Components: Core Framework
    Affects Versions: 1.13.2, 1.6.0
            Reporter: Zhang Haoran


There are some FlowFiles in a queue, and the "priority" attribute of each 
FlowFile is "9". PriorityAttributePrioritizer is set to the queue.

When the number of FlowFiles in the queue does not exceed the value of 
"nifi.queue.swap.threshold", and a new FlowFile with attribute "priority" value 
"1" transfered into the queue, it will be ranked at first of the queue;

But when the number of FlowFiles exceeds the threshold, another FlowFile with 
the attribute "priority" value "1" into the queue cannot be ranked at first. 
This FlowFile may be directly swapped to disk, so the prioritizer is not 
working.

Reproduced on 1.6.0 and the newest release 1.13.2, may exist in all versions



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to