- Apache Flink 教程
- Apache Flink - 主页
- Apache Flink - 大数据平台
- 批处理与实时处理
- Apache Flink - 简介
- Apache Flink - 架构
- Apache Flink - 系统要求
- Apache Flink - 设置/安装
- Apache Flink - API 概念
- Apache Flink - Table 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
广告