Hi Davood,
The streaming part of Flink currently does not support managed memory;
all memory is allocated directly on the heap (apart from the network
buffers). There are plans to change that in the future.
The batch side uses manages memory, e.g. see ReduceCombineDriver.
Cheers,
Max
On Sat, J
Hi community,
I am using WordCount example in DataStream API. I want to know the memory
usage of each task and operator and possible modify them.
As far as I know, the memory(off-heap or heap) is retrieved through
MemoryManager.
There is, releaseAll(Object owner) method in MemoryManager, that
