Hi everybody, Thanks so much for looking into this issue and posting the detailed description of your approach. As said before, improving the checkpointing performance for timers is a very important improvement for Flink.
I'm not familiar with the internals of the timer service checkpointing, but adding an add and delete version field and perform async checkpoints based on these fields seems like a good approach to me. IIRC, Aljoscha (in CC) implemented the timer service and its checkpointing. He might have more comments. I'd suggest to create a JIRA (everybody can do that) and repost the description of your approach there. If you have the code ready, you can also open a PR and reference the JIRA. Best, Fabian 2018-04-16 9:03 GMT+02:00 makeyang <riverbuild...@hotmail.com>: > since flink forward SF has done. > can you guys give some minutes to take a look at this issue and give some > thoughts on it? help to review/comments on my desgin? or give us a design > so > that I can help to implement it. > > thanks a lot. > > > > -- > Sent from: http://apache-flink-user-mailing-list-archive.2336050. > n4.nabble.com/ >
