GG-13361 Compilation
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3f346afa Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3f346afa Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3f346afa Branch: refs/heads/ignite-7505 Commit: 3f346afa31ab6cc5da3769b51ddc8eedc89e47c9 Parents: 1a4ceae Author: Alexey Goncharuk <[email protected]> Authored: Tue Jan 23 11:33:50 2018 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Tue Jan 23 11:33:50 2018 +0300 ---------------------------------------------------------------------- .../processors/affinity/GridAffinityAssignmentCache.java | 9 +++++++++ 1 file changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/3f346afa/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityAssignmentCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityAssignmentCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityAssignmentCache.java index dd46246..47f5612 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityAssignmentCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/affinity/GridAffinityAssignmentCache.java @@ -194,6 +194,15 @@ public class GridAffinityAssignmentCache { assert topVer.compareTo(lastVersion()) >= 0 : "[topVer = " + topVer + ", last=" + lastVersion() + ']'; assert idealAssignment != null; + DiscoCache discoCache = ctx.discovery().discoCache(topVer); + + if (ctx.cache().cacheGroup(grpId).persistenceEnabled()) { + for (List<ClusterNode> pNodes : affAssignment) { + for (ClusterNode pNode : pNodes) + assert discoCache.baselineNode(pNode.id()); + } + } + GridAffinityAssignment assignment = new GridAffinityAssignment(topVer, affAssignment, idealAssignment); affCache.put(topVer, new HistoryAffinityAssignment(assignment));
