如题,pyflink场景的任务,内存是如何管理呢。

python部分的内存是否算入flink TaskManager配置的内存中呢?
比如python算子通过多进程做各种复杂的运算,这部分内存占用是否算入flink呢?



——————
如果不算的话,使用pyflink时,容器内存和flink TaskManager内存配置是不是需要预留空间?

回复