I've created a JIRA:
https://issues.apache.org/jira/browse/FLINK-3322
Best,
Gábor
2016-01-30 14:36 GMT+01:00 Fabian Hueske :
> Hi Gabor and Marton,
>
> the taskmanager.memory.preallocate switch basically replaces Flink's
> streaming mode.
> The current stream runtime code does not operate on ma
Hi Gabor and Marton,
the taskmanager.memory.preallocate switch basically replaces Flink's
streaming mode.
The current stream runtime code does not operate on managed memory. Hence,
all memory allocated by the memory manager cannot be used for streaming
jobs and is "lost". If the switch is set to f
Hello!
We have a strangely behaving iterative Flink job: when we give it more
memory, it gets much slower (more than 10 times). The problem seems to
be mostly caused by GCs. Enabling object reuse didn’t help.
With some profiling and debugging, we traced the problem to the
operators requesting new
