Uploaded image for project: 'Apache NiFi'
  1. Apache NiFi
  2. NIFI-8744

FlowFile queue Prioritizers will not work when queued count exceeds nifi.queue.swap.threshold

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.6.0, 1.13.2
    • Fix Version/s: None
    • Component/s: Core Framework
    • Labels:
      None

      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

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              super_dachuan super dachuan
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: