Hi everyone, I spent the week-end putting the pieces together to run Beam with the Flink Runner on Kubernetes. While I did find very good articles and videos about Beam and Flink and Kubernetes separately, I didn't find one that mixes all three of them in the same pot.
So, I wrote a small demo project/tutorial combining all the bits and pieces of information I found on my quest. It's here https://github.com/zeidoo/tutorial-bean-flink-kubernetes-pojo. Any feedback is welcome. I hope it helps someone. Cheers everyone! PS: I didn't find on the Beam documentation website that the easiest way to pass PoJos around transforms is to make them implement Serializable. I've put a small section about that in the tutorial.
