
- 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

廣告