Repository: ignite Updated Branches: refs/heads/ignite-1534 b3816961c -> bb509cd07
ignite-1534 debug Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/bb509cd0 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/bb509cd0 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/bb509cd0 Branch: refs/heads/ignite-1534 Commit: bb509cd078f6d40f648c5e85da9c4f18287479cf Parents: b381696 Author: sboikov <[email protected]> Authored: Thu Oct 1 11:39:26 2015 +0300 Committer: sboikov <[email protected]> Committed: Thu Oct 1 11:39:26 2015 +0300 ---------------------------------------------------------------------- .../processors/cache/GridCachePartitionExchangeManager.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/bb509cd0/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java index 7c5c4fa..a1487da 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java @@ -359,8 +359,10 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana } } - for (GridCacheContext cacheCtx : cctx.cacheContexts()) - cacheCtx.preloader().onInitialExchangeComplete(null); + for (GridCacheContext cacheCtx : cctx.cacheContexts()) { + if (cacheCtx.startTopologyVersion() == null) + cacheCtx.preloader().onInitialExchangeComplete(null); + } if (log.isDebugEnabled()) log.debug("Finished waiting for initial exchange: " + fut.exchangeId());
