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 is called from Task class when releasing the resources. However, I could not find how the operator gets the required memory (heap or off-heap) from MemoryManager. Cheers Davood
