Installation

Prerequisites

• maven
• JDK 21
• Flink 1.19.0 (download from here)

1. Install maven deps:

2. Extract Flink archive into the project root:

Build

make build

Launch Nodes

Run in separate terminal seshions/processes:

make node1

make node2

Launch Mock Event Generators

make events1 events2

Centralized Flink Cluster

Not relevant for the project, keeping the docs for reference.

Build with:

mvn clean package

Start Flink cluster from the folder with Flink files:

./bin/start-cluster.sh

Submit the built JAR to the cluster:

${path_to_flink_folder}/bin/flink run target/my-app-1.0-SNAPSHOT.jar