[
https://issues.apache.org/jira/browse/IGNITE-426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14723292#comment-14723292
]
ASF GitHub Bot commented on IGNITE-426:
---------------------------------------
GitHub user ntikhonov opened a pull request:
https://github.com/apache/ignite/pull/52
IGNITE-426 Implemented sending partition counter to backups node for …
…transaction caches. Added tests.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ntikhonov/ignite ignite-426
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/ignite/pull/52.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #52
----
commit 987c3dca090c73d8b10af09648db32c3de9c3f55
Author: nikolay_tikhonov <[email protected]>
Date: 2015-08-31T10:36:44Z
IGNITE-426 Implemented sending partition counter to backups node for
transaction caches. Added tests.
----
> Make sure continuous queries notifications are not missed in case primary
> node fails
> ------------------------------------------------------------------------------------
>
> Key: IGNITE-426
> URL: https://issues.apache.org/jira/browse/IGNITE-426
> Project: Ignite
> Issue Type: Sub-task
> Components: cache
> Reporter: Yakov Zhdanov
> Assignee: Semen Boikov
> Priority: Critical
> Fix For: ignite-1.4
>
>
> * Maintain updates queue on backup node(s) in addition to primary node.
> * If primary node crushes, this queue is flushed to listening clients.
> * To avoid notification duplicates we will have a per-partition update
> counter. Once an entry in some partition is updated, counter for this
> partition is incremented on both primary and backups. The value of this
> counter is also sent along with the update to the client, which also
> maintains the copy of this mapping. If at some moment it receives an update
> with the counter less than in its local map, this update is a duplicate and
> can be discarded.
> * To cleanup the backup queue we will use communication acks. When batch
> receival is acked by the client, we will send special ack message to backup
> nodes that will remove items that are not longer needed. This message has to
> contain partition to latest update counter map.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
