Hi Eduardo, Flink 1.9 will add a new State Processor API [1], which you can use to create Savepoints from scratch with a batch job.
Cheers, Konstantin [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/libs/state_processor_api.html#writing-new-savepoints On Thu, Jul 4, 2019 at 12:38 AM Eduardo Winpenny Tejedor < eduardo.winpe...@gmail.com> wrote: > Hi all, > > How would one go about migrating a stateful streaming application that > doesn't use Flink to one that does? > > My question is specifically how to load state for the first time? I can > set the source operator (Kafka in my case) to start from a desired point in > time but I've no idea how I'd go about initialising the state of the Flink > equivalent version of the app from a "pseudo-snapshot". I call > "pseudo-snapshot" to the non-Flink representation of state at a given point > in time. > > Thanks, > Eduardo > -- Konstantin Knauf | Solutions Architect +49 160 91394525 Planned Absences: 10.08.2019 - 31.08.2019, 05.09. - 06.09.2010 -- Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany -- Ververica GmbH Registered at Amtsgericht Charlottenburg: HRB 158244 B Managing Directors: Dr. Kostas Tzoumas, Dr. Stephan Ewen
