[NIFI-8744] FlowFile queue Prioritizers will not work when queued count exceeds nifi.queue.swap.threshold

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.6.0, 1.13.2
• Component/s: Core Framework
• Assignee: Unassigned
• Reporter: super dachuan
• Created: 26/Jun/21 06:16
• Updated: 26/Jun/21 06:16

Description

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