Hi Aviad,

sorry for the late reply.
You can configure the checkpoint directory (which is also used for
externalized checkpoints) when you create the state backend:

env.setStateBackend(new RocksDBStateBackend("hdfs:///checkpoints-data/");

This configures the checkpoint directory to be hdfs:///checkpoints-data.

Best, Fabian

2017-11-16 9:26 GMT+01:00 aviad <rotem.av...@gmail.com>:

> Hi,
>
> thanks for the answer.
> I can use the first option (REST API).
> for some reason it is undocumented in flink documentation
> (https://ci.apache.org/projects/flink/flink-docs-
> release-1.3/monitoring/rest_api.html)
>
> regarding the second option, configure each job with an externalized
> checkpoint directory.
> I don't see how I can do it.
> from flink documentation:
> "The target directory for the externalized checkpoint’s meta data is
> determined from the configuration key state.checkpoints.dir which,
> currently, *can only be set via the configuration files.*"
>
> do I messing something?
> do I have another way to configure externalized checkpoint?
>
> thanks
> Aviad
>
>
>
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.
> n4.nabble.com/
>

Reply via email to