Hi!
I'm thinking about using a great Flink functionality - savepoints . I would
like to be able to stop my streaming application, rollback the state of it
and restart it (for example to update code, to fix a bug). Let's say I
would like travel back in time and reprocess some data.
But what if I had many streaming applications running, that's states are
correlated, like in microservice architecture? I would like to travel back
in time in all of my services to a common point in time. Is there a
possibility to somehow manage correlated savepoints? Of course I can
trigger savepointing at approximately same time, but it's just an
approximation, right?
Is there something in Flink that could support this advanced use case?
Maybe someone else hit this issue already and thought about the solution?
I'll be grateful for any comments,
Cheers,
Krzysztof
