Подключение к Flink через CLI
Flink имеет CLI-интерфейс для запуска и контроля программ, упакованных в виде Java-архивов (jar). Для создания новой задачи (job), необходимо загрузить jar-файл со всеми зависимостями в активный кластер Flink и запустить jar. Примеры задач доступны в директории /usr/lib/flink/examples/.
Чтобы развернуть демонстрационное приложения WordCount в запущенном кластере, выполните следующую команду:
$ flink run /usr/lib/flink/examples/streaming/WordCount.jarВы можете запустить другие примеры из директории аналогичным способом. Большинство примеров не требуют аргументов и используют данные, зашитые в приложение. Чтобы запустить WordCount.jar с реальными данными, укажите путь к входным данным:
$ ./bin/flink run ./examples/batch/WordCount.jar --input /path/to/some/text/data --output /path/to/result|
Примечание
Для работы с удаленной файловой системой необходимо указать префикс, например hdfs://.
|
Результат выполнения задачи можно увидеть в лог-файлах:
$ tail log/flink-*-taskexecutor-*.outПример вывода:
(nymph,1) (in,3) (thy,1) (orisons,1) (be,4) (all,2) (my,1) (sins,1) (remember,1) (d,4)