Prerequisite

• Install Apache Flink
• Start the cluster (follow the instruction from official documentation)
• Have JDK 11 installed
• You can also install Flink using Homebrew

Create JAR

mvn clean package

To start a Socket

nc -l 9999

To run Flink job, open a new terminal and submit Flink job

• If you have installed Flink using Homebrew the below command should work.

flink run /path/to/jarfile

• otherwise, if you have installed flink using Binary.

./bin/flink run /path/to/jarfile

Join Discord in case you have any query.