Yes, exactly. This is a little cumbersome at the moment, but there are plans to improve this after 1.2 is released.
– Ufuk On 16 January 2017 at 16:33:49, tao xiao (xiaotao...@gmail.com) wrote: > 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 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 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. > > >
