[IGNITE-9787] Local Continuous Query skips rows during initial rebalance of REPLICATED cache

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 2.4
• Labels: cq_todo
• Assignee: Unassigned
• Reporter: Ilya Kasnacheev
• Created: 03/Oct/18 15:53
• Updated: 30/May/20 15:33

Description

This is observer under .Net but I assume will affect Java too:

If you have a partitioned cache with non-local continuous query, continuous query will iterate every entry in REPLICATED cache.
If you have a replicated cache with non-local continuous query, it works.
If you have a replicated cache with local continuous query and synchronous rebalancing, it also works.
But if you have replicated cache with local continuous query and non-synchronous rebalancing , you will see the gap in data - newly written entries while rebalance is underway may not be passed to callback or scan query.

Please see the ML thread and reproducer.

Issue Links

• links to: Userlist thread