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/08/07 15:03:18 UTC
ignite git commit: IGNITE-5872 - Fixed LOCAL topology handling
Repository: ignite
Updated Branches:
refs/heads/ignite-5872 f47df9e89 -> 2874f75e1
IGNITE-5872 - Fixed LOCAL topology handling
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2874f75e
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2874f75e
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2874f75e
Branch: refs/heads/ignite-5872
Commit: 2874f75e1830795140d997b1d9d9c6fe4848c499
Parents: f47df9e
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Mon Aug 7 18:03:12 2017 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Mon Aug 7 18:03:12 2017 +0300
----------------------------------------------------------------------
.../dht/preloader/GridDhtPartitionsExchangeFuture.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/2874f75e/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
index 168b7ab..53532ab 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
@@ -1738,8 +1738,10 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
}
}
- for (CacheGroupContext grpCtx : cctx.cache().cacheGroups())
- grpCtx.topology().applyUpdateCounters();
+ for (CacheGroupContext grpCtx : cctx.cache().cacheGroups()) {
+ if (!grpCtx.isLocal())
+ grpCtx.topology().applyUpdateCounters();
+ }
if (discoEvt.type() == EVT_NODE_JOINED)
assignPartitionsStates();