State Memory Leak Issue in Flink CEP v1.17: Discussion & Proposed Solution

[Puneet Duggal <pu...@gmail.com>]

Hi,

We have encountered a state memory leak issue while working with the Flink CEP (Complex Event Processing) in version 1.17. Based on code, it seems like the issue is persistent across all versions of CEP library.

I've already raised a JIRA issue detailing the problem we've faced. You can find the detailed description, steps to replicate, and other pertinent information within this ticket: https://issues.apache.org/jira/browse/FLINK-32701

Furthermore, I've also included a potential solution in the comments section of the JIRA issue. This solution has been tested in our specific use-cases and appears to address the problem effectively. To expedite discussions on a this critical production blocker we've encountered as well as ensuring the correctness of the proposed solution, I'm reaching out to the community.

Thanks,
Puneet