When starting a job from within the IDE using the LocalEnvironment, it is not possible to specify a checkpoint from which to resume. That's why your recovered state is empty. Flink won't automatically pick up the latest checkpoint it finds in some checkpoint directory.
You can test it though by starting a local standalone cluster and submit the job via bin/flink run -s <PATH_TO_CHECKPOINT> job.jar [1]. [1] https://ci.apache.org/projects/flink/flink-docs-stable/ops/cli.html#restore-a-savepoint Cheers, Till On Fri, Jan 4, 2019 at 2:49 PM Puneet Kinra < puneet.ki...@customercentria.com> wrote: > The List it returns is blank > > On Fri, Jan 4, 2019 at 7:15 PM Till Rohrmann <trohrm...@apache.org> wrote: > >> Hi Puneet, >> >> what exactly is the problem when you try to resume from a checkpoint? >> >> Cheers, >> Till >> >> On Fri, Jan 4, 2019 at 2:31 PM Puneet Kinra < >> puneet.ki...@customercentria.com> wrote: >> >>> Hi All >>> >>> I am creating a poc where i am trying the out of box feature of flink >>> for managed state of operator . I am able to create the checkpoint while >>> running my app in eclipse but when i am trying to restart the app . I am >>> unable to restore >>> the state. >>> >>> Please find attached below snippet. >>> >>> step followed >>> 1) ran the application that generate tuple automatically. >>> 2) check-pointing is triggering as it configured.(able to see the data >>> being written in files) >>> 3) stopped the app in eclipse >>> 4) restart the application (unable to restore) >>> >>> >>> >>> -- >>> *Cheers * >>> >>> *Puneet* >>> >> > > -- > *Cheers * > > *Puneet Kinra* > > *Mobile:+918800167808 | Skype : puneet.ki...@customercentria.com > <puneet.ki...@customercentria.com>* > > *e-mail :puneet.ki...@customercentria.com > <puneet.ki...@customercentria.com>* > > >
