gmflau/apache-flink-examples

Apache Flink Examples

Prerequisites:

• JDK installed
• mvn installed
• Flink installed

Download the repo:

git clone https://github.com/gmflau/apache-flink-examples
cd apache-flink-examples

For userClickEvents:

cd userClickEvents

Edit and update this line to reflect your local directory:

String outputPathForTenPlus = "/Users/glau/Documents/Flink/UserEvents/output/userevents_10plus";

Edit and update this line to reflect your local directory:

String outputPathForLessThanTen = "/Users/glau/Documents/Flink/UserEvents/output/userevents_less_than_10";

Build:

mvn clean install

Submit a Flink job locally:

flink run target/task-1.2.2-SNAPSHOT.jar

Apache Flink Dashboard

Running Jobs: User Click Events Job Page: