Hi everyone,
I am trying to implement savepoint mechanism for my Flink project.
Here is the scenario:
I got the snapshot of Flink application by using "flink savepoint <JobId>"
command while the application is running.
After saving snapshot of application, I canceled the job from web ui than I
changed the topology of Flink application.
(To change the topology, I split the keyedstream into two seperate keyedstream)
After changing the topology, I run the new application by using the snapshot
which I took in first step.
But after running the application, the window which has been snapshot, triggers
without the new log.
Question is: Is there any way to save old window state to continue after
starting new topology with snapshot?