如何生成电源关闭警报使用flink流。e、 x:我有一个网站,通过Kafka向flink job发送数据。 比方说,我们在1992年4月26日10:23:52收到数据,在那个站点出现问题之后,它没有发送任何数据。在这种情况下,我们要生成一个警报,说电源关闭。有可能用flink吗?
wn9m85ua1#
这种心跳故障检测很容易用 ProcessFunction . 文档中有一个例子。您也可以使用cep执行此操作:https://stackoverflow.com/a/60754081/2000823
ProcessFunction
1条答案
按热度按时间wn9m85ua1#
这种心跳故障检测很容易用
ProcessFunction
. 文档中有一个例子。您也可以使用cep执行此操作:https://stackoverflow.com/a/60754081/2000823