flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ufuk Celebi <...@apache.org>
Subject Re: Savepoint for time windows
Date Mon, 18 Apr 2016 15:43:28 GMT
Can you please share the program before and after the savepoint?

– Ufuk

On Mon, Apr 18, 2016 at 3:11 PM, Ozan DENİZ <ozandeniz@outlook.com> wrote:
> 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?
>

Mime
View raw message