Re: Flink CEP exception during RocksDB update

Hi Varun, The branch I previously sent you has been now merged to the master. So could you try the master and tell us if you see any change in the behavior? Has the problem been fixed, or has the message of the exception changed? Thanks, Kostas > On Jan 29, 2018, at 10:09 AM, Kostas Kloudas

Re: Flink CEP exception during RocksDB update

Hi again Varun, I am investigating the problem you mentioned and I found a bug in the SharedBuffer, but I am not sure if it is the only bug that affects you. Could you please try this branch https://github.com/kl0u/flink/tree/cep-inv and let me know

Re: Flink CEP exception during RocksDB update

Hi Varun, Thanks for taking time to look into it. Could you give a sample input and your pattern to reproduce the problem? That would help a lot at figuring out the cause of the problem. Thanks, Kostas > On Jan 23, 2018, at 5:40 PM, Varun Dhore wrote: > > Hi Kostas, > > I was able to reprodu

Re: Flink CEP exception during RocksDB update

Hi Kostas, I was able to reproduce the error with 1.4.0. After upgrading the cluster to 1.5 snapshot and running through the same data I am still experiencing the same exception. CEP patterns that I am running are using followed by patterns e.g AfBfC. From my experience I was never able to get

Re: Flink CEP exception during RocksDB update

Thanks a lot Varun! Kostas > On Jan 17, 2018, at 9:59 PM, Varun Dhore wrote: > > Thank you Kostas. Since this error is not easily reproducible on my end I’ll > continue testing this and confirm the resolution once I am able to do so. > > Thanks, > Varun > > Sent from my iPhone > > On Jan 1

Re: Flink CEP exception during RocksDB update

Thank you Kostas. Since this error is not easily reproducible on my end I’ll continue testing this and confirm the resolution once I am able to do so. Thanks, Varun Sent from my iPhone > On Jan 15, 2018, at 10:21 AM, Kostas Kloudas > wrote: > > Hi Varun, > > This can be related to this iss

Re: Flink CEP exception during RocksDB update

Hi Varun, This can be related to this issue: https://issues.apache.org/jira/browse/FLINK-8226 which is currently fixed on the master. Could you please try the current master to see if the error persists? Thanks, Kostas > On Jan 15, 2018, at 4

Flink CEP exception during RocksDB update

> Hello Flink community, > > I have encountered following exception while testing 1.4.0 release. This > error is occurring intermittently and my CEP job keeps restarting after this > exception. I am running the job with Event time semantics and checkpoints > enabled. > > > ja