When the JobManager/TaskManager are starting up they log what config they are loading. Look for lines like
"Loading configuration property: {}, {}" Do you find the required configuration as part of these messages? – Ufuk On Tue, Dec 19, 2017 at 3:45 PM, Plamen Paskov <plamen.pas...@next-stream.com> wrote: > Hi, > I'm trying to enable externalized checkpoints like this: > > env.enableCheckpointing(1000); > CheckpointConfig checkpointConfig = env.getCheckpointConfig(); > checkpointConfig.enableExternalizedCheckpoints(CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION); > checkpointConfig.setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE); > env.setStateBackend(new > FsStateBackend("file:///tmp/flink-checkpoints-data/", true)); > > in flink-conf.yaml i set: > state.checkpoints.dir: file:///tmp/flink-checkpoints-meta/ > > but when i run the application i get this error: > 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'. > > Any suggestions? > > Thanks