Не удается установить приложение flink

Question

Я использую Hortonworks 2.4.0.

Я начинаю пряжу-сессию с ./bin/yarn-session.sh -n 1 -jm 768 -tm 768

Затем я хочу, чтобы развернуть ./bin/flink запустить -m yarn- cluster -yn 1 -yjm 768 -ytm 768 ./examples/batch/WordCount.jar

Когда я развертываю свое приложение, я сталкиваюсь с бесконечным циклом. Сообщение регистрации: INFO org.apache.flink.yarn.FlinkYarnClient - Развертывание заняло более 60 секунд. Проверьте, имеются ли запрошенные ресурсы в кластере ЯРН

Я уже настроил параметры для n 1 -jm 768 -tm для различных значений. В том числе, как рекомендовано в: https://ci.apache.org/projects/flink/flink-docs-release-1.0/setup/yarn_setup.html Это не решило проблему.

Answer 1

С командой ./bin/yarn-session.sh -n 1 -jm 768 -tm 768 вы начинаете длительную сессию YARN.

Вы можете отправить задание на сессию с использованием ./bin/flink клиента (без прохождения -m пряжи кластера аргумента)

Если вы хотите отправить одно задание на пряжу с помощью Flink, ./bin/flink run -m yarn-cluster -yn 1 -yjm 768 -ytm 768 является правильным подходом к подаче задания.