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, вы сможете увидеть выполненную работу с ее деталями.

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

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

cat output.txt