Re: Flink memory leak

2017-11-10 Thread ÇETİNKAYA EBRU ÇETİNKAYA EBRU
EBRU ÇETİNKAYA EBRU wrote: On 2017-11-10 13:14, Piotr Nowojski wrote: jobmanager1.log and taskmanager2.log are the same. Can you also submit files containing std output? Piotrek On 10 Nov 2017, at 09:35, ÇETİNKAYA EBRU ÇETİNKAYA EBRU wrote: On 2017-11-10 11:04, Piotr Nowojski wrote: Hi

Re: Flink memory leak

2017-11-09 Thread ÇETİNKAYA EBRU ÇETİNKAYA EBRU
ory fraction, changes this value in the taskmanager.sh "TM_MAX_OFFHEAP_SIZE="2G"; and nothing seems to work. Thanks for your help. On 8 November 2017 at 13:26, ÇETİNKAYA EBRU ÇETİNKAYA EBRU wrote: On 2017-11-08 15:20, Piotr Nowojski wrote: Hi Ebru and Javier, Yes, if you coul

Re: Flink memory leak

2017-11-08 Thread ÇETİNKAYA EBRU ÇETİNKAYA EBRU
ter every job.. We've tried to reproduce this problem with a test (see https://issues.apache.org/jira/browse/FLINK-7845 [1]) but we don't know whether the error produced by the test and the leak are correlated.. Best, Flavio On Wed, Nov 8, 2017 at 9:51 AM, ÇETİNKAYA EBRU ÇETİNKAYA EBRU w

Flink memory leak

2017-11-07 Thread ÇETİNKAYA EBRU ÇETİNKAYA EBRU
Hi, We are using Flink 1.3.1 in production, we have one job manager and 3 task managers in standalone mode. Recently, we've noticed that we have memory related problems. We use docker container to serve Flink cluster. We have 300 slots and 20 jobs are running with parallelism of 10. Also the