ApacheFlink-Flinkプログラムの実行

この章では、Flinkプログラムの実行方法を学習します。

FlinkクラスターでFlinkワードカウントの例を実行してみましょう。

Flinkのホームディレクトリに移動し、ターミナルで以下のコマンドを実行します。

bin/flink run examples/batch/WordCount.jar -input README.txt -output /home/ubuntu/flink-1.7.1/output.txt

Flinkダッシュボードに移動すると、完了したジョブとその詳細を確認できます。

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

ワードカウントプログラムの出力を確認するには、ターミナルで以下のコマンドを実行します。

cat output.txt