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

Semen Boikov commented on IGNITE-5290:
--------------------------------------

Currently I'm doing changes in CQ code and faced the same issue. This caused by 
the fact that in GridCacheMapEntry.innerUpdate collection of CQ listeners to 
notify if initialized before partition update counter is incremented. Looks 
like to avoid this error it should work in this way:
- first get snapshot of listeners (in the same place it is obtained now)
- execute update logic
- before notifying listeners, again get snapshot of listeners, if it changed 
then for all added listeners mark current counter as filtered

> Events might be missed during concurrent CQ registration and cache operations
> -----------------------------------------------------------------------------
>
>                 Key: IGNITE-5290
>                 URL: https://issues.apache.org/jira/browse/IGNITE-5290
>             Project: Ignite
>          Issue Type: Bug
>    Affects Versions: 2.0
>            Reporter: Nikolay Tikhonov
>         Attachments: test.patch
>
>
> Events might be missed during concurrent CQ registration and cache 
> operations. See attached test.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to