[
https://issues.apache.org/jira/browse/FLINK-40237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-40237:
-----------------------------------
Labels: pull-request-available (was: )
> 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
> Priority: Major
> Labels: pull-request-available
>
> 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)
