Repository: ignite Updated Branches: refs/heads/ignite-5272 d9c19d3bd -> b51a10464
ignite-5272 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b51a1046 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b51a1046 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b51a1046 Branch: refs/heads/ignite-5272 Commit: b51a10464b03a9ae0450a204ff92e2b0c7f77aa2 Parents: d9c19d3 Author: sboikov <[email protected]> Authored: Thu Jun 15 06:07:07 2017 +0300 Committer: sboikov <[email protected]> Committed: Thu Jun 15 06:07:07 2017 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/cache/GridCacheProcessor.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/b51a1046/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java index fb03f06..febdf0f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java @@ -2099,10 +2099,12 @@ public class GridCacheProcessor extends GridProcessorAdapter { if (ctx == null) continue; - if (ids == null) - ids = U.newHashSet(cachesToClose.size()); + if (!ctx.affinityNode()) { + if (ids == null) + ids = U.newHashSet(cachesToClose.size()); - ids.add(ctx.cacheId()); + ids.add(ctx.cacheId()); + } if (!ctx.affinityNode() && !locked) { // Do not close client cache while requests processing is in progress.
