Search code examples
apache-flinkflink-streamingflink-sql

Flink checkpointing failing in Kubernetes with FsStateBackend

I am getting the error as stated below while using flink in kubernetes with per job state backend of FsStateBackend like so -: env.setStateBackend(new FsStateBackend("file:///data/flink/checkpoints"))

I am setting it in my code itself.

Error -: Mkdirs failed to create file:/data/flink/checkpoints/3321ab76ccf319397f5b52be25f6cd8d Can someone suggest resolution for this -:

Thanks in advance. Cheers!!

Solution

  • In addition to what @chuckskull pointed out, also make sure that this file URI is accessible to every pod in your cluster. All of the task managers and the job manager have to be able to read and write the checkpoint files using this URI.