Hi Ufuk, Thank you for the reply. I want to know what the difference is between state.backend.fs.checkpoint.dir and state.checkpoints.dir in this case? Does state.checkpoint.dir store the metadata that points to the checkpoint that is stored in state.backend.fs.checkpoint.dir?
On Mon, 16 Jan 2017 at 19:24 Ufuk Celebi <u...@apache.org> wrote: > Hey! > > This is possible with the upcoming 1.2 version of Flink (also in the > current snapshot version): > > https://ci.apache.org/projects/flink/flink-docs-release-1.2/setup/checkpoints.html#externalized-checkpoints > > You have to manually activate it via the checkpoint config (see docs). > > Ping me if you have any questions. > > – Ufuk > > > On Mon, Jan 16, 2017 at 5:51 AM, tao xiao <xiaotao...@gmail.com> wrote: > > Hi team, > > > > Can we restart a flink job from previous successful checkpoint? I know we > > can start a flink from a savepoint but I wonder if I can do it similar by > > passing the checkpoint path to the flink run command to restore the job > from > > checkpoint. >
