Re: set state.checkpoint.dir to execution environment

Posted by Tony Wei on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/set-state-checkpoint-dir-to-execution-environment-tp15349p15350.html

Hi Jose,

It seems that you enable the externalized checkpoints in your streaming job.

If enabling externalized checkpoints is what you really want to, 'state.checkpoints.dir' must be set in flink-conf.yaml.

For your second question, yes, the only way is to modify the flink-conf.yaml. See the reference https://ci.apache.org/projects/flink/flink-docs-release-1.3/setup/checkpoints.html#directory-structure.

Best,

Tony Wei

2017-09-03 7:09 GMT+08:00 Jose Miguel Tejedor Fernandez <[hidden email]>:

Hi,

After enabling checkpoints and set the property env.setStateBackend(new FsStateBackend(url)) I am the following exception:

Caused by: java.lang.IllegalStateException: CheckpointConfig says to persist periodic checkpoints, but no checkpoint directory has been configured. You can configure configure one via key 'state.checkpoints.dir'.

I have not found any way to set the 'state.checkpoints.dir' to the execution environment. Is it possible? or the only way is to modify the file flink-conf.yaml instead? 

Thanks

BR