Учебники

Apache Flink – Запуск программы Flink

В этой главе мы узнаем, как запустить программу Flink.

Давайте запустим пример подсчета слов Flink на кластере Flink.

Перейдите в домашний каталог Flink и запустите приведенную ниже команду в терминале.

bin/flink run examples/batch/WordCount.jar -input README.txt -output /home/ubuntu/flink-1.7.1/output.txt

Домашний каталог Flink

Перейдите на панель инструментов Flink, вы сможете увидеть выполненную работу с ее деталями.

Приборная панель Flink

Если вы нажмете на Завершенные задания, вы получите подробный обзор работ.

Нажмите Завершенные вакансии

Чтобы проверить вывод программы wordcount, запустите приведенную ниже команду в терминале.