Aitozi opened a new pull request #7543: [FLINK-10996]Fix the possible state leak with CEP processing time model URL: https://github.com/apache/flink/pull/7543 ## What is the purpose of the change In flink cep, if user uses the `within` syntax under processing time semantic， there is no clean up mechanism for the stored partial state, If the data for the `KEY` never come again. Which will lead to the state leak. And fix a little error about java doc in flink-cep module ## Brief change log - Register a timer for per key to check the data with the interval of `1000ms` ## Verifying this change covered by the test case `CEPOperatorTest#testCEPOperatorCleanupExpireDataWithOutComparatorProcessingTime`
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
