【Flink】Flink 源码之Buffer Debloating1.概述2.什么是Buffer debloating3.buffer debloating 源代码解析
1.概述转载:【Flink】Flink 源码之Buffer Debloating2.什么是Buffer debloatingBuffer Debloating是Flink 1.14新增的优化方式。它能够根据指标(buffer数据被全部消费的期望等待时间taskmanager.network.memory.buffer-debloat.target)自动推算和控制in-flight data(operator输入队列和输出队列缓存的数据)大小,从而减少checkpoint耗时,减少checkpoi