Submit your program through Flink UI

On your own PC, open the browser and enter the following url.

http://node-1.cse.cuhk.edu.hk:<port of Flink WebUI>

Click "Submit New Job" on the left pane.

Click "Add New", and select the JAR you just scp to your machine.

Click on the row of the uploaded JAR file. Press Submit.

A statistic page for your program is displayed. The middle graph shows the execution plan of the current job. The table below shows the statistic of the stream. You can see that the FlatMap stage keeps on emitting Records to the Aggregation stage.

Open back the terminal that docker-compose is executed.

You can see that it keeps on printing records since we defined PrintSink in our Java program.

Note: Remember to Cancel your Job before you leave.