Re: Need help to understand memory consumption

2018-10-17 Thread jpreisner
0月17日(星期三) 14:35 收件人:Zhijiang(wangzhijiang999) < wangzhijiang...@aliyun.com > 抄 送:jpreisner < jpreis...@free.fr >; user < user@flink.apache.org > 主 题:Re: Need help to understand memory consumption Hi Zhijiang, Does the memory management apply to streaming jobs as well? A previous po

Re: JobManager did not respond within 60000 ms

2018-10-09 Thread jpreisner
Hi Piotrek, Thank you for your answer. Actually it was necessary to increase the memory of the JobManager (I had tested it but I had not restarted Flink ...). I will also work on optimization. I thought it was good practice to create as much function as possible based on their functional value

JobManager did not respond within 60000 ms

2018-10-09 Thread jpreisner
I have a streaming job that works in standalone cluster. Flink version is 1.4.1. Everything was working so far. But since I added new treatments, I can not start my job anymore. I have this exception : org.apache.flink.client.program.ProgramInvocationException: The program execution failed: