ignite-5485 Fixed NPE, though need investigate if such state ist ok in processFullPartitionUpdate.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/353e5442 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/353e5442 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/353e5442 Branch: refs/heads/ignite-5267-1 Commit: 353e5442d06b3193bb32bd33091c7bc879e3272f Parents: 5b8eb60 Author: sboikov <[email protected]> Authored: Thu Jun 15 15:18:51 2017 +0300 Committer: sboikov <[email protected]> Committed: Thu Jun 15 15:18:51 2017 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/GridDhtPartitionTopologyImpl.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/353e5442/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 da06710..e8fcef9 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 @@ -2030,7 +2030,10 @@ public class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology { lock.readLock().lock(); try { - assert node2part != null && node2part.valid() : "Invalid node2part [node2part: " + node2part + + if (node2part == null) + return false; + + assert node2part.valid() : "Invalid node2part [node2part: " + node2part + ", grp=" + grp.cacheOrGroupName() + ", stopping=" + stopping + ", locNodeId=" + ctx.localNodeId() +
