YuXiang Zhou created FLINK-40237:
------------------------------------
Summary: CepOperator does not clean up expired NFA state in
processing-time timer callbacks
Key: FLINK-40237
URL: https://issues.apache.org/jira/browse/FLINK-40237
Project: Flink
Issue Type: Bug
Components: Library / CEP
Environment:
Reporter: YuXiang Zhou
This is a follow-up to FLINK-32701
(https://issues.apache.org/jira/browse/FLINK-32701).
CepOperator cleans up dangling NFA state in onEventTime(), but the equivalent
cleanup is missing from onProcessingTime().
onProcessingTime() should apply the same cleanup logic as onEventTime() and
clear computationStates when only the initial partial match remains and there
are no completed matches.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
