Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-7377

Implement FixedBufferPool for floating buffers in SingleInputGate

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Closed
    • Major
    • Resolution: Duplicate
    • 1.4.0
    • None
    • None
    • None

    Description

      Currently the number of network buffers in LocalBufferPool for SingleInputGate is limited by a * <number of channels> + b, where a is the number of exclusive buffers for each channel and b is the number of floating buffers shared by all channels.

      Considering the credit-based flow control feature, we want to implement a new fixed size buffer pool type used to manage the floating buffers for SingleInputGate.

      Compared with LocalBufferPool, this is a non-rebalancing buffer pool which will not participate in redistributing the left available buffers in NetworkBufferPool.

      Attachments

        Activity

          People

            zjwang Zhijiang
            zjwang Zhijiang
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: