Truong Duc Kien created NIFI-5864:
-------------------------------------

             Summary: Incorrect drainedSize calculation in 
SwappablePriorityQueue
                 Key: NIFI-5864
                 URL: https://issues.apache.org/jira/browse/NIFI-5864
             Project: Apache NiFi
          Issue Type: Bug
    Affects Versions: 1.8.0
            Reporter: Truong Duc Kien


When the size of {{expiredRecords}} is equal to 
{{MAX_EXPIRED_RECORDS_PER_ITERATION}}, the loop break early and {{drainSized}} 
will not include the last record.

https://github.com/apache/nifi/blob/5561c29ed3b8c635f499582e983a5147cb06e306/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/queue/SwappablePriorityQueue.java#L650



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to