Re: How to know (in code) how many times the job restarted?

2021-06-13 Thread Felipe Gutierrez
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

Re: Flink PrometheusReporter support for HTTPS

2021-06-13 Thread Ashutosh Uttam
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