hi,community,
我最近有一个业务场景,需要基于消息流和具体的业务逻辑判断生成超时事件,考虑通过flink 
cep来实现。不过在这个场景中,需要针对输入的消息,判断如果一个小时内没有匹配的数据到来,就需要把该事件输出。
目前的cep机制,应该需要下一个事件消息到来时才会输出事件。想请教下各位大神,针对这个诉求有没有啥好的方案。
感谢。

回复