Hi,

yes, that is correct, the timer service is currently only available in 
main-memory and only with synchronous snapshots. this topic is on our TODO list 
for after the Flink 1.5 release.

Best,
Stefan

> Am 16.03.2018 um 09:03 schrieb Fabian Hueske <fhue...@gmail.com>:
> 
> Hi,
> 
> AFAIK, that's not possible. 
> The only "solution" is to reduce the number of timers. Whether that's 
> possible or 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 
> <mailto:lindeqiang1...@gmail.com>>:
> 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
> 

Reply via email to