In this chapter, we will learn how to run a Flink program.

Let us run the Flink wordcount example on a Flink cluster.

Go to Flink”s home directory and run the below command in the terminal.

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

Go to Flink dashboard, you will be able to see a completed job with its details.

If you click on Completed Jobs, you will get detailed overview of the jobs.

To check the output of wordcount program, run the below command in the terminal.

cat output.txt