Hello Flink Users,

I have a requirement to generate alerts for metrics like for example - if
cpu utilization spike i.e *cpu_utilization > threshold* (>90%) n number of
time in x minutes then generate alerts. For this I am using the CEP module.
However, one of the requirements is for different devices the threshold can
be different as ell as x and n in above statement. Moreover, for different
device class this will be different, also this can change in future.
I am thinking of using Broadcast State Pattern and enrich the metrics
stream with this thresholds & rule and use it later in CEP pattern. One
issue is how to make sure that if new threshold values come in how the
broadcast stream will change. I have an understanding that if I can
introduce a watermark in broadcast stream when values change the
KeyedBroadcastProcessFunction will have latest values streamed.
Is my understanding correct and if anyone has implemented something like
this can weigh in if this is right way to do it.

Thanks,
Hemant

Reply via email to