Setup
sudo apt-get update
sudo apt-get install openjdk-11-jdk
sudo apt install maven
Download Flink
Download from https://www.apache.org/dyn/closer.lua/flink/flink-1.16.0/flink-1.16.0-bin-scala_2.12.tgz, add the bin directory (containing start-cluster.sh, stop-cluster.sh and flink) into PATH
Compile existing examples
cd flink/flink-examples
mvn install -DskipTests -Dgpg.skip=true -DfailIfNoTests=false -Dskip.installnodenpm -Dskip.npm -Dskip.yarn -Dlicense.skip -Dcheckstyle.skip -Drat.skip -Denforcer.skip -Danimal.sniffer.skip -Dmaven.javadoc.skip -Dfindbugs.skip -Dwarbucks.skip -Dmodernizer.skip -Dimpsort.skip -Dmdep.analyze.skip -Dpgpverify.skip -Dxml.skip -Dcobertura.skip=true -Dfindbugs.skip=true
Run jar file
start-cluster.sh
cd /home/ubuntu/flink/flink-examples/flink-examples-streaming
# If change source file, use `mvn install` for compilation
mvn install -DskipTests -Dcheckstyle.skip -Dspotless.check.skip
cd target
# rm -rf out # clear old directory
flink run SessionWindowing.jar --output /home/ubuntu/flink/flink-examples/flink-examples-streaming/target/out
less out/ # use tab for auto-completion
stop-cluster.sh