Ошибка контрольной точки Flink в Kubernetes с FsStateBackend

Я получаю сообщение об ошибке, указанное ниже, при использовании flink в кубернетах с бэкэндом состояния задания FsStateBackend, например: env.setStateBackend(new FsStateBackend("file:///data/flink/checkpoints"))

Я устанавливаю это в самом коде.

Ошибка -: Mkdirs failed to create file:/data/flink/checkpoints/3321ab76ccf319397f5b52be25f6cd8d Может кто-нибудь предложить решение для этого -:

Заранее спасибо. Ваше здоровье!!


apache-flink flink-streaming flink-sql
person Anish Sarangi    schedule 14.05.2020    source источник

Ответы (2)


arrow_upward
0
arrow_downward

В дополнение к тому, что указал @chuckskull, также убедитесь, что этот URI файла доступен для каждого модуля в вашем кластере. Все диспетчеры задач и диспетчер заданий должны иметь возможность читать и записывать файлы контрольных точек, используя этот URI.

person David Anderson    schedule 14.05.2020

arrow_upward
0
arrow_downward

Вот несколько вещей, которые вы можете проверить:

  • Убедитесь, что /data/flink/checkpoints существует.
  • Убедитесь, что пользователь, выполняющий задание flink, имеет доступ для чтения / записи к этому каталогу.
person damjad    schedule 14.05.2020