Hi Red!
Thank you for your interest and for checking out the official Flink
Kubernetes Operator Project.
This project is still relatively new and so far our focus has been on
running native Flink workloads (Flink Application/Session clusters, and
session jobs) and we haven't tried running a Flink
I created an example project with my attempts to get something working:
https://github.com/gonzojive/beam-go-k8s
The good news is I got something working with Beam, Go, Bazel, Flink, and
Kubernetes (minikube). The working version doesn't use the operator and
only runs in a single pod.
I would st
