Hi Lei, 我理解这篇文章少介绍了 keyby 的逻辑。 可以keyby(robotId),然后在 processFunction 里面使用 ValueState 存储最近一次 robot 的到达时间, 同时注册一个 20min 的timer来触发检测,在检测时候,取出 ValueState 的值都是同一个 robotId的。
Best, hailong 在 2020-11-11 12:54:22,"Lei Wang" <leiwang...@gmail.com> 写道: >有很多边缘机器人设备(我们称为 robot)往 Kafka 中发消息,如果超过一定时间没有收到消息我们就认为 robot 掉线了。 > >比如 >robot1 2020-11-11 12:00:00 msginfo >之后 20 mins 一直没有收到 robot1 的消息,怎样才才能在 flink 中实现 2020-11-11 12:10:00 就发出报警呢? > >flink 是消息驱动的,没有收到消息就不会触发操作,怎样在没有收到后续消息的条件下触发操作呢? > >我试验了下 https://juejin.im/post/6844904193052901384 的例子,不满足我的应用场景。 > >这个例子相当于所用订单共用一个 timeService, 每一次遍历一下所有的订单。 >我们必须 按 robotId 做 keyBy > >求大神指教。 > >谢谢, >王磊