Awesome. Thanks. On Thu, May 25, 2017 at 10:13 PM, Eron Wright <eronwri...@gmail.com> wrote:
> Yes, registered timers are stored in managed keyed state and should be > fault-tolerant. > > -Eron > > On Thu, May 25, 2017 at 9:28 AM, Moiz S Jinia <moiz.ji...@gmail.com> > wrote: > >> With a checkpointed RocksDB based state backend, can I expect the >> registered processing timers to be fault tolerant? (along with the managed >> keyed state). >> >> Example - >> A task manager instance owns the key k1 (from a keyed stream) that has >> registered a processing timer with a timestamp thats a day ahead in the >> future. If this instance is killed, and the key is moved to another >> instance, will the onTimer trigger correctly on the other machine at the >> expected time with the same keyed state (for k1)? >> >> Thanks, >> Moiz >> > >
