I just realised that only the ProcessFunction is enough. I don't need the
CheckpointFunction.
On Fri, 11 Jun 2021, 18:11 Felipe Gutierrez,
wrote:
> Cool!
>
> I did using this example
> https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/state/state.html#using-managed-operator
Hi Austin,
I am deploying Flink on K8s with multiple Job Manager pods (For HA) & Task
Manager pods.
Each JobManager & Task Manager are running an PrometheusReporter instance
and using Prometheus’ service discovery support for Kubernetes to discover
all pods (Job Manager & Task Manager) and expos