Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-8581 Improve performance for low latency network
  3. FLINK-8786

SpillableSubpartitionView#getNextBuffer always sets isMoreAvailable to false when switching from spillable to spilled

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Blocker
    • Resolution: Fixed
    • None
    • 1.5.0
    • Runtime / Network
    • None

    Description

      When processing the last in-memory buffer in SpillableSubpartitionView#getNextBuffer, we always set the isMoreAvailable flag of the returned BufferAndBacklog to false irrespective of what may be in the spill writer.

      Attachments

        Issue Links

          Activity

            People

              nkruber Nico Kruber
              nkruber Nico Kruber
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: