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
廣告