- Apache Flink 教程
- Apache Flink - 主页
- Apache Flink - 大数据平台
- 批处理与实时处理
- Apache Flink - 简介
- Apache Flink - 架构
- Apache Flink - 系统要求
- Apache Flink - 设置/安装
- Apache Flink - API 概念
- Apache Flink - 表 API 和 SQL
- 创建 Flink 应用程序
- Apache Flink - 运行 Flink 程序
- Apache Flink - 库
- Apache Flink - 机器学习
- Apache Flink - 用例
- Apache Flink - Flink、Spark、Hadoop
- Apache Flink - 结论
- Apache Flink 资源
- Apache Flink - 快速指南
- Apache Flink - 有用的资源
- Apache Flink - 讨论
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 仪表板,您将能够看到已完成的作业及其详细信息。
如果您单击已完成的作业,您将获得作业的详细概述。
要检查 wordcount 程序的输出,请在终端中运行以下命令。
cat output.txt