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?
                                          

Reply via email to