Не удалось создать файловую систему для высокодоступного хранилища - PullRequest
0 голосов
/ 30 апреля 2019

У меня есть три физических узла с установленным докером на каждом из них. Я настроил Mesos, Marathon, Zookeeper, Hadoop и Flink на каждом докере. Я могу без проблем запускать Mesos, Marathon, Zookeeper и hadoop; также я сделал папку flink в hdfs. Кстати, я настроил высокодоступный кластер hadoop и работаю без проблем. Но когда я использую этот файл JSON для запуска flink на Marathon, я получаю невыполненную задачу в Mesos UI. Ошибка в следующем:

Завершение работы MesosSessionClusterEntrypoint с состоянием приложения FAILED. Диагностика java.io.IOException: Не удалось создать файловую систему для высокодоступного хранилища (high-Availability.storageDir)

Моя конфигурация флинка такая:

env.java.home: /opt/java
jobmanager.rpc.address: 10.32.0.1
high-availability: zookeeper
high-availability.storageDir: hdfs:///flink/ha/ 
high-availability.zookeeper.quorum: 10.32.0.1:2181,10.32.0.2:2181
recovery.zookeeper.path.mesos-workers: /mesos-workers
mesos.master: 10.32.0.1:5050,10.32.0.2:5050

Подскажите, пожалуйста, как решить проблему? Нужно ли подключать флинк к мезо?

Заранее спасибо.

1 Ответ

0 голосов
/ 11 мая 2019

Проблема решена с этой конфигурацией:

jobmanager.rpc.address: localhost
high-availability.zookeeper.quorum: 
 10.32.0.1:2181,10.32.0.2:2181,10.32.0.3:2181
mesos.master: 10.32.0.1:5050,10.32.0.2:5050,10.32.0.3:5050 
...