作者:北极光的悲伤 | 来源:互联网 | 2024-10-15 20:00
2.概述NetworkEnvironment是每个Instance的网络IO组件,包含了追踪中间结果和数据交换的数据结构。它的构造器会统一将配置的内存先分配出来,抽象成Netw
2.概述
NetworkEnvironment 是每个 Instance 的网络 IO 组件,包含了追踪中间结果和数据交换的数据结构。它的构造器会统一将配置的内存先分配出来,抽象成 NetworkBufferPool 统一管理内存的申请和释放。
2.1 拓扑图
2.2 . BufferPool
从 MemoryManager 的介绍中我们讲到 flink 是以 MemorySegment 为单位来管理内存的,而一个 MemorySegment 又被叫做一个 Buffer。BufferPool 是管理 Buffer 的工具。Buffer 的申请统一交给 NetworkBufferPool,具体的管理交给 LocalBufferPool。
3. 字段
LocalBufferPool的逻辑想想无非是增删改查&#