Hello,

With Flink CEP, is there a way to actively listen to pattern matches that
time out? I am under the impression that this is not possible.

In my case I partition a stream containing user web navigation by "userId"
to look for sequences of Event A, followed by B within 4 seconds for each
user.

I registered a PatternTimeoutFunction which assuming a non-match only fires
upon the first event after the specified timeout. For example, given user
X: Event A, 20 seconds later Event B (or any other type of event).

I'd rather have a notification fire directly upon the 4 second interval
expiring since passive invalidation is not really applicable in my case.

How, if at all can this be achieved with Flink CEP?

Thanks,

David

Reply via email to