如何使用flink-streaming生成断电警报。
e.x:我有一个网站,通过kafka发送数据到flink-job。
比方说,我们在1992年4月26日10:23:52收到了数据,因为该站点出现了一些问题,它没有发送任何数据。在这种情况下,我们希望生成一个显示为POWER_OFF的警报。
可以使用flink吗?
发布于 2020-04-26 21:43:34
这种类型的心跳故障检测很容易通过ProcessFunction完成。在documentation中有一个例子。
您也可以使用CEP:https://stackoverflow.com/a/60754081/2000823来完成此操作。
https://stackoverflow.com/questions/61436018
复制相似问题