我一直在研究flink。我对flink中的内存管理有疑问。如何在flink中管理内存。在flink中是否有类似“火花中的块”的类似功能?如果有关于flink内存管理的好地方,请告诉我。
Flink实现了自己的内存管理,称为托管内存。托管内存解决了使用JVM的堆内存时通常遇到的问题,如垃圾收集,内存布局和难以预测的对象大小。使用托管内存,Flink能够在数据增长时正常溢出到磁盘,并且可以避免长时间的垃圾收集暂停/减少垃圾收集压力,因为托管内存部分不受GC影响。
您可以找到有关Flink的托管内存here和here的更多信息。