Hello everyone,
I'm new to Flink and Python is my language of choice when it comes to development. I have been trying to get into Flink for the past 2 weeks and it has been a little rough. I came across this video on Youtube, (
Robust Stream Processing with Apache Flink▾
from 2016, and it seems like a great introduction to stateful processing. I do not know Java/Scala that well and I have been struggling to try to replicate what is done in the video in Python. Right now I am using Flink v1.15.2 with Python 3.8. I came on here for help and guidance from a community of people who have more than likely been doing this longer than me 🤣
I kind of understand what's going on in the video, but the data generator and the keyed process is confusing to me. If I can get past creating that myself then I think I can replicate that whole video in Python and learn a lot along the way. Is there anybody who can help? 😩