cc user@, bcc dev@
Hi Dhruv,
Yes, this should be totally possible.
For 1, I would use a ProcessFunction to buffer the alerts and register
timers per alert for the repeated firing (or to clear it from state if it
is resolved). From this ProcessFunction you send records to an
AlertManagerSink.
Fo
Hi,
We have a use case where we want to send alerts to Prometheus
Alertmanager (https://prometheus.io/docs/alerting/latest/alertmanager/)
from Flink. Each of these alerts have a startsAt, endsAt field along with
alertMetadata. Alertmanager expects clients to send all the FIRING alerts
every X mi
