You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/11/25 21:13:00 UTC

[jira] [Commented] (FLINK-10996) Enable state ttl in cep

    [ https://issues.apache.org/jira/browse/FLINK-10996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698304#comment-16698304 ] 

Stephan Ewen commented on FLINK-10996:
--------------------------------------

+1 that sounds like it is needed to harden CEP.

If you want to contribute a fix, can you please describe here briefly how you intend to implement this?

> Enable state ttl in cep
> -----------------------
>
>                 Key: FLINK-10996
>                 URL: https://issues.apache.org/jira/browse/FLINK-10996
>             Project: Flink
>          Issue Type: Improvement
>          Components: CEP
>    Affects Versions: 1.7.1
>            Reporter: aitozi
>            Assignee: aitozi
>            Priority: Major
>             Fix For: 1.7.1
>
>
> In flink cep, although the within clause can clean up the data when data is expire. But If the specific key data never come again, the partial matched data will not be deleted again which will lead to the state leak. With the state ttl feature support by flink runtime, we has the ability to expire the correlative data asyncly . 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)