+1 LGTM. RocksDB timer service is one of the most highly anticipated features from Flink users, and it's finally coming, officially. I also would love to see bringing timer more closely to state backend, for the sake of easier development and maintenance of code.
On Fri, May 25, 2018 at 7:13 AM, Stefan Richter <s.rich...@data-artisans.com > wrote: > Hi, > > I am currently planning how to improve Flink’s timer management for large > state. In particular, I would like to introduce timer state that is managed > in RocksDB and also to improve the capabilities of the heap-based timer > service, e.g. support for asynchronous checkpoints. You can find a short > outline of my planned approach in this document: > > https://docs.google.com/document/d/1XbhJRbig5c5Ftd77d0mKND1bePyTC > 26Pz04EvxdA7Jc/edit?usp=sharing > > As always, your questions, feedback, and comments are highly appreciated. > > Best, > Stefan