flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Davood Rafiei <rafieidavo...@gmail.com>
Subject About Memory usage
Date Sat, 11 Jun 2016 11:11:27 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message