Fixed updateCounter when node is removed (backport of 4fedd0fe)
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ace80299 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ace80299 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ace80299 Branch: refs/heads/ignite-2.1 Commit: ace802990822fa9a68ddb9824a159dacedc05901 Parents: c475f27 Author: Ivan Rakov <[email protected]> Authored: Tue Jul 4 17:45:37 2017 +0300 Committer: Ivan Rakov <[email protected]> Committed: Tue Jul 4 17:45:37 2017 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/GridDhtPartitionTopologyImpl.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/ace80299/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java index a6f1831..f24dd45 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java @@ -1934,12 +1934,11 @@ public class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology { ClusterNode loc = ctx.localNode(); if (node2part != null) { - if (loc.equals(oldest) && !node2part.nodeId().equals(loc.id())) { - updateSeq.setIfGreater(node2part.updateSequence()); + updateSeq.setIfGreater(node2part.updateSequence()); + if (loc.equals(oldest) && !node2part.nodeId().equals(loc.id())) node2part = new GridDhtPartitionFullMap(loc.id(), loc.order(), updateSeq.incrementAndGet(), node2part, false); - } else node2part = new GridDhtPartitionFullMap(node2part, node2part.updateSequence());
