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