Re: Slow flink checkpoint

2018-04-16 Thread
Hi Stefan , Fabian , Keyang is engineer in our team, he has do a lot of efforts on the timers' snapshot async. What do you think of his idea? Best, Deqiang TIG.JD.COM > 在 2018年4月1日,下午7:21,makeyang 写道: > > I have put a lot of

Re: Slow flink checkpoint

2018-03-16 Thread
not, depends on the application. > For example, if you use timers to clean up state, you can work with an > upper and lower bound and only register one timer for each (upper - lower) > interval. > > Best, Fabian > > 2018-03-16 3:11 GMT+01:00 林德强 <lindeqiang1...@gmail.com>

Slow flink checkpoint

2018-03-15 Thread
Hi, I'm run a job on Flink streaming. I found with the increase in the number of 'InternalTimer' object the checkpoint more and more slowly. Is there any way to solve this problem ? such as make the "timeServiceManager" snapshot async. Thanks