你好， python部分的内存算flink taskmanager 配置的内存，你应该可以用参数 *'taskmanager.memory.task.off-heap.size* 来配置，可以参考这个问题： https://stackoverflow.com/questions/64323031/pyflink-1-11-2-couldn-t-configure-taskmanager-memory-task-off-heap-size-proper
On Wed, 24 Aug 2022 at 1:05 PM, yidan zhao <hinobl...@gmail.com> wrote: > 如题，pyflink场景的任务，内存是如何管理呢。 > > python部分的内存是否算入flink TaskManager配置的内存中呢？ > 比如python算子通过多进程做各种复杂的运算，这部分内存占用是否算入flink呢？ > > > > —————— > 如果不算的话，使用pyflink时，容器内存和flink TaskManager内存配置是不是需要预留空间？ >
