如何使用 flink-streaming 生成关机警报
How to generate power off alert using flink-streaming
如何使用 flink-streaming 生成关机警报。
e.x: 我有一个站点通过 kafka 向 flink-job 发送数据。
比方说，我们在 1992 年 4 月 26 日收到数据 10:23:52，在该站点出现问题后它没有发送任何数据。在这种情况下，我们想要生成一个提示 POWER_OFF。
可以使用flink吗？
这种心跳故障检测很容易用 ProcessFunction 完成。 documentation 中有一个示例。
您也可以使用 CEP 执行此操作：
如何使用 flink-streaming 生成关机警报。
e.x: 我有一个站点通过 kafka 向 flink-job 发送数据。
比方说，我们在 1992 年 4 月 26 日收到数据 10:23:52，在该站点出现问题后它没有发送任何数据。在这种情况下，我们想要生成一个提示 POWER_OFF。
可以使用flink吗？
这种心跳故障检测很容易用 ProcessFunction 完成。 documentation 中有一个示例。
您也可以使用 CEP 执行此操作：