[jira] [Created] (FLINK-18727) Remove the previous finished empty Buffer in PipelinedSubpartition when adding a new Buffer

[Shang Yuanchun (Jira)]

Yingjie Cao created FLINK-18727:
-----------------------------------

             Summary: Remove the previous finished empty Buffer in PipelinedSubpartition when adding a new Buffer
                 Key: FLINK-18727
                 URL: https://issues.apache.org/jira/browse/FLINK-18727
             Project: Flink
          Issue Type: Improvement
          Components: Runtime / Network
            Reporter: Yingjie Cao
             Fix For: 1.12.0


For current implementation of PipelinedSubpartition, empty Buffer consumes credit, which means we need at lease one credit to handle the finished empty Buffer without any data. We can remove and recycle the finished empty Buffer in the queue when adding a new Buffer, after which, the reader does not need any available credit to handle the finished empty buffer. For example, if the new buffer is an event and the previous buffer is finished but without any data, after it is removed, the reader is able to process the new added event without any available credit.



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