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
>
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
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
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.
