Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.
Kubernetes operator for that acts as control plane to manage the complete deployment lifecycle of Apache Flink applications. This is an open source fork of GoogleCloudPlatform/flink-on-k8s-operator with several new features and bug fixes.
Beta
The operator is under active development, backward compatibility of the APIs is not guaranteed for beta releases.
The Kubernetes Operator for Apache Flink extends the vocabulary (e.g., Pod, Service, etc) of the Kubernetes language with custom resource definition FlinkCluster and runs a controller Pod to keep watching the custom resources. Once a FlinkCluster custom resource is created and detected by the controller, the controller creates the underlying Kubernetes resources (e.g., JobManager Pod) based on the spec of the custom resource. With the operator installed in a cluster, users can then talk to the cluster through the Kubernetes API and Flink custom resources to manage their Flink clusters and jobs.
The operator is still under active development, there is no Helm chart available yet. You can follow either
ghcr.io/spotify/flink-operator
to your Kubernetes
cluster orPlease check CONTRIBUTING.md and the Developer Guide out.