Repository: ignite Updated Branches: refs/heads/ignite-1093-3 9dfdb6999 -> 8033dc77f
1093 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/8033dc77 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/8033dc77 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/8033dc77 Branch: refs/heads/ignite-1093-3 Commit: 8033dc77fdf8dc4ca045eab5809240523543296c Parents: 9dfdb69 Author: Anton Vinogradov <[email protected]> Authored: Wed Oct 28 15:31:13 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Wed Oct 28 15:31:13 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/preloader/GridDhtPartitionDemander.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/8033dc77/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java index deedf21..adb6de2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java @@ -869,6 +869,9 @@ public class GridDhtPartitionDemander { private void cleanupRemoteContexts(UUID nodeId) { ClusterNode node = cctx.discovery().node(nodeId); + if (node == null) + return; + //Check remote node rebalancing API version. if (node.version().compareTo(GridDhtPreloader.REBALANCING_VER_2_SINCE) >= 0) {
