[Flink kubernetes operator] Usage of HorizontalPodAutoscaler

2023-02-23 Thread Ritesh Nadhani
Hello I was reviewing the HPA example at: https://github.com/apache/flink-kubernetes-operator/blob/main/examples/hpa/basic-hpa.yaml and I am a bit confused as to which spec this applies to. Practically, I would assume that it's for scaling TaskManager worker pods. Is that correct? Then how does

[Flink-Kubernetes-Operator] Beam example application getting into "State: RECONCILING" after minikube restart

2023-02-18 Thread Ritesh Nadhani
Hello This is my first setup with Apache Beam and trying to use the flink runner for it. Following the example of https://github.com/apache/flink-kubernetes-operator/tree/main/examples/flink-beam-example I got my app running inside my local minikube. The app is pretty stateless - minimal transform