Как «запустить одно задание Flink на YARN» по API остальных? - PullRequest
Новая
       10

Как «запустить одно задание Flink на YARN» по API остальных?

0 голосов
/ 26 января 2019

Из официального документа Flink мы знаем, что мы можем «запустить одно задание Flink по YARN» с помощью приведенной ниже команды, мой вопрос: можем ли мы «запустить одно задание Flink по YARN» с помощью Rest API и получить API приложения? 

./bin/flink run -m yarn-cluster -yn 2 ./examples/batch/WordCount.jar

1 Ответ

0 голосов
/ 30 января 2019

См. (Несколько обманчиво названное) Мониторинг REST API . Вы можете использовать запрос /jars/upload для отправки вашего (fat / uber) файла jar в кластер. Возвращает идентификатор, который вы можете использовать с запросом /jars/:jarid/run, чтобы начать работу.

Если вам также нужно запустить кластер, то вам (AFAIK) понадобится написать код Java для запуска кластера на YARN. В Flink есть два исходных файла, которые делают то же самое:

...