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 <[email protected]> Authored: Mon Aug 7 18:03:12 2017 +0300 Committer: Alexey Goncharuk <[email protected]> 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();
