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 程序的输出,请在终端中运行以下命令。

cat output.txt
输出字数统计程序