Re: Example of Beam Go job that uses Flink Kubernetes operator

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

Re: Example of Beam Go job that uses Flink Kubernetes operator

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

Example of Beam Go job that uses Flink Kubernetes operator

Hi, This is a request for documentation to walk through using the Flink Kubernetes operator with the Go Beam SDK. I will plan to update the thread as I investigate. I hope this feedback is useful. A few observations: 1) The official "Quick Start guide