You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2017/07/17 12:27:21 UTC
[12/12] ignite git commit: IGNITE-5757 - Fixed missed topology update
IGNITE-5757 - Fixed missed topology update
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2e239d71
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2e239d71
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2e239d71
Branch: refs/heads/ignite-5757
Commit: 2e239d7131655a14726cf7a0763c16ee72e4c9fa
Parents: db161a6
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Mon Jul 17 15:26:47 2017 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Mon Jul 17 15:26:47 2017 +0300
----------------------------------------------------------------------
.../cache/distributed/dht/GridDhtPartitionTopologyImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/2e239d71/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 d0db02b..6cd19cb 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
@@ -639,7 +639,7 @@ public class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology {
updateRebalanceVersion(aff);
if (node2part != null && node2part.valid())
- checkEvictions(updateSeq, aff);
+ changed |= checkEvictions(updateSeq, aff);
consistencyCheck();
}