flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Maximilian Michels <...@apache.org>
Subject Re: About Memory usage
Date Mon, 13 Jun 2016 10:02:14 GMT
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.


On Sat, Jun 11, 2016 at 1:11 PM, Davood Rafiei <rafieidavood9@gmail.com> wrote:
> 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

View raw message