Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-7315 use flink's buffers in netty
  3. FLINK-7517

let NettyBufferPool extend PooledByteBufAllocator

    XMLWordPrintableJSON

Details

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

    Description

      NettyBufferPool wraps PooledByteBufAllocator but due to this, any allocated buffer's alloc() method is returning the wrapped PooledByteBufAllocator which allowed heap buffers again. By extending the PooledByteBufAllocator, we prevent this loop hole and also fix the invariant that a copy of a buffer should have the same allocator.

      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: