You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@nifi.apache.org by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/12/04 08:11:01 UTC

[jira] [Created] (NIFI-5864) Incorrect drainedSize calculation in SwappablePriorityQueue

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)