Apache Flink - 运行 Flink 程序



在本章中,我们将学习如何运行 Flink 程序。

让我们在 Flink 集群上运行 Flink wordcount 示例。

转到 Flink 主目录并在终端中运行以下命令。

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

转到 Flink 仪表盘,您将能够看到一个完成的任务及其详细信息。

Flink dashboard

如果您单击“完成任务”,您将获得任务的详细概览。

Click Completed Jobs

要检查 wordcount 程序的输出,请在终端中运行以下命令。

cat output.txt
Output Wordcount Program
广告