Repository: ignite Updated Branches: refs/heads/ignite-2.0 decb0c7aa -> 9020d12fc
Fixed assert. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/9020d12f Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/9020d12f Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/9020d12f Branch: refs/heads/ignite-2.0 Commit: 9020d12fc9dbcf39db545b0c8abfc50a324fbd77 Parents: decb0c7 Author: sboikov <[email protected]> Authored: Fri Mar 17 11:24:15 2017 +0300 Committer: sboikov <[email protected]> Committed: Fri Mar 17 11:24:15 2017 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/GridDhtPartitionTopologyImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/9020d12f/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java index 53257d3..c476886 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java @@ -1434,12 +1434,12 @@ class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology { ClusterNode oldest = discoCache.oldestAliveServerNode(); - assert oldest != null; + assert oldest != null || cctx.kernalContext().clientNode(); ClusterNode loc = cctx.localNode(); if (node2part != null) { - if (oldest.equals(loc) && !node2part.nodeId().equals(loc.id())) { + if (loc.equals(oldest) && !node2part.nodeId().equals(loc.id())) { updateSeq.setIfGreater(node2part.updateSequence()); node2part = new GridDhtPartitionFullMap(loc.id(), loc.order(), updateSeq.incrementAndGet(),
