Apache Flink - Menjalankan Program Flink

Di bab ini, kita akan mempelajari cara menjalankan program Flink.

Mari kita jalankan contoh Wordcount Flink pada kluster Flink.

Buka direktori home Flink dan jalankan perintah di bawah ini di terminal.

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

Pergi ke dasbor Flink, Anda akan dapat melihat pekerjaan yang sudah selesai dengan detailnya.

Jika Anda mengklik Pekerjaan yang Diselesaikan, Anda akan mendapatkan gambaran umum rinci pekerjaan tersebut.

Untuk memeriksa output dari program wordcount, jalankan perintah di bawah ini di terminal.

cat output.txt