Nico Kruber created FLINK-8755:

             Summary: SpilledSubpartitionView wrongly relys on the backlog for 
determining whether more data is available
                 Key: FLINK-8755
             Project: Flink
          Issue Type: Sub-task
          Components: Network
            Reporter: Nico Kruber
            Assignee: Nico Kruber
             Fix For: 1.5.0

public BufferAndBacklog getNextBuffer() throws IOException, 
InterruptedException {
        int newBacklog = parent.decreaseBuffersInBacklog(current);
        return new BufferAndBacklog(current, newBacklog > 0, newBacklog, 
relies on the backlog to signal further data availability. However, if there 
are only events left in the buffer queue, their buffers are not included in the 
backlog counting and therefore, {{isMoreAvailable}} will be wrongly {{false}} 

This message was sent by Atlassian JIRA

Reply via email to