CEP 无法检测到具有相同时间戳的多事件



当我在 Flink 中使用 CEP 时,我发现一件非常有趣的事情是一次只有一个事件。

例如,我使用的 DataStream 来自 WindowStream,因为它可能会更新同一事件的发生次数,它会生成类似这样的东西:(事件 1, 2(、(事件 1, 3(、(事件 2, 1(......

当我尝试选择将模式应用于此输出数据流的结果时,我发现只有(事件 1, 2(、(事件 2, 1(....

有人可以给我一些线索吗?这是图案设计的问题还是 Flink 这样工作

我找到了答案。这是因为:

CEP 库假定水印在工作时正确无误 事件时间。

详情在 处理事件时间迟到/Fink 文档中

最新更新