[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-10-12 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16201731#comment-16201731 ] Kostas Kloudas commented on FLINK-7606: --- Hi [~i...@paolorendano.it] ! I will close this issue, as I

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-10-09 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16197094#comment-16197094 ] Kostas Kloudas commented on FLINK-7606: --- I do not think that this would solve the problem. In event

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-10-05 Thread Paolo Rendano (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16193026#comment-16193026 ] Paolo Rendano commented on FLINK-7606: -- IMO the timeout should be triggered after the expiration of

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-10-05 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16192994#comment-16192994 ] Kostas Kloudas commented on FLINK-7606: --- You are right! There is already a discussion about

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-10-05 Thread Paolo Rendano (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16192891#comment-16192891 ] Paolo Rendano commented on FLINK-7606: -- HI [~kkl0u], 1) exactly 2) exactly, but my stream is a never

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-10-05 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16192818#comment-16192818 ] Kostas Kloudas commented on FLINK-7606: --- Hi [~i...@paolorendano.it], Sorry for the late reply.

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-09-26 Thread Paolo Rendano (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181713#comment-16181713 ] Paolo Rendano commented on FLINK-7606: -- Hi [~kkl0u], 1) sure I have to set and I was not setting it

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-09-25 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16179089#comment-16179089 ] Kostas Kloudas commented on FLINK-7606: --- Perfect! Thanks a lot! > CEP operator leaks state >

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-09-22 Thread Paolo Rendano (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16176654#comment-16176654 ] Paolo Rendano commented on FLINK-7606: -- Hi [~kkl0u], sorry this week was hard also for me. Next week

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-09-18 Thread Matteo Ferrario (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170001#comment-16170001 ] Matteo Ferrario commented on FLINK-7606: Hi [~kkl0u], thanks for your reply. If I understand

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-09-15 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16168158#comment-16168158 ] Kostas Kloudas commented on FLINK-7606: --- Now that I think about it, can you check your watermarks

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-09-15 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16168099#comment-16168099 ] Kostas Kloudas commented on FLINK-7606: --- Also, on another note, I read that you have fewer results

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-09-15 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16168090#comment-16168090 ] Kostas Kloudas commented on FLINK-7606: --- Yes [~i...@paolorendano.it]. This holds for every keyed

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-09-15 Thread Paolo Rendano (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16168025#comment-16168025 ] Paolo Rendano commented on FLINK-7606: -- Hi [~kkl0u], from your comment I understand that the basic

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-09-15 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16167954#comment-16167954 ] Kostas Kloudas commented on FLINK-7606: --- It should be cleared. In event time, we do not have

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-09-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16167635#comment-16167635 ] Aljoscha Krettek commented on FLINK-7606: - How do you mean? They could get the timed-out partially

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-09-14 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16167242#comment-16167242 ] Dian Fu commented on FLINK-7606: I think this is by design otherwise users could not get the timed out

[jira] [Commented] (FLINK-7606) CEP operator leaks state

2017-09-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166340#comment-16166340 ] Aljoscha Krettek commented on FLINK-7606: - Will NFAs not be cleared when the allowed "within" time