Hello!

Our team works with Flink CEP library for real time events processing. But
we noticed that some non-matching events are lost. We propose some changes
in the Flink CEP library that provide the ability to handle non-matching
events.

We propose adding a new interface  UnmatchedEventsHandler similar to
TimedOutPartialMatchHandler, and add a state for storing all events in
CepOperator.

More information in FLIP document
https://docs.google.com/document/d/1V5QldVFUOLRggIJzAoESLm8Orkk9th7f4o0Y0gsolh4/edit?usp=sharing

Reply via email to