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

Apache-flink-running-program