🎉 I just ran my first Apache Flink cluster and application on it 🎉
I followed the First Steps quickstart from the Flink docs which is a nicely-paced walk through:
0️⃣ make sure you’ve got Java 11
1️⃣ install Flink (download, unpack (with a little detour))
2️⃣ run it (./bin/start-cluster.sh
)
3️⃣ submit the sample WordCount app
4️⃣ see the execution in the web UI
5️⃣ examine the output
The WebUI is a nice touch - sometimes just running everything on the CLI gives you a technically correct finish but if you’re new to something leaves you underwhelmed. The webUI lets you click around a bit and start to get a feel for what’s going on.
You can find the source for the WordCount app here, and further tutorials on Flink here.