FlinkCEP 尽可能多的匹配的问题

lp Thu, 13 May 2021 05:52:59 -0700

我有一个flinkCEP程序，采用eventTime，监控形如如下的数据
[13/May/2021:20:45:36 +0800]
[13/May/2021:20:45:36 +0800]
[13/May/2021:20:45:37 +0800]
[13/May/2021:20:45:37 +0800]
[13/May/2021:20:45:50 +0800]




程序中关键设置如下：
设置了水印延迟2s
跳过测略AfterMatchSkipStrategy.skipPastLastEvent()

.times(3)
.within(Time.seconds(3));



结果得到如下结果：
detected 3 access in 60s from same ip...[/45:36, /45:36, /45:37]
迟到输出的数据...[/45:37],发生超时的时间戳是：：2021-05-13 08:45:40


其实我想得到结果是：
在[13/May/2021:20:45:50 +0800]这条数据到来时，我想得到这样的结果：detected 3 access in 60s from
same ip...[/45:36, /45:36, /45:37, /45:37]
；因为他们都满足我.times(3).within(Time.seconds(3))的设置;

所以我应该怎样做？





--
Sent from: http://apache-flink.147419.n8.nabble.com/

FlinkCEP 尽可能多的匹配的问题

回复