Apache-flink-running-program

提供:Dev Guides
2020年6月23日 (火) 10:03時点におけるMaintenance script (トーク | 投稿記録)による版 (Imported from text file)
(差分) ← 古い版 | 最新版 (差分) | 新しい版 → (差分)
移動先:案内検索

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

[完了したジョブ]をクリックすると、ジョブの詳細な概要が表示されます。

完了ジョブをクリック

wordcountプログラムの出力を確認するには、ターミナルで次のコマンドを実行します。

cat output.txt

Wordcountプログラムの出力