1093
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d78e4cdb Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d78e4cdb Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d78e4cdb Branch: refs/heads/ignite-1093-3 Commit: d78e4cdbe1799231f4dd0a4fe5de0ff9b9300343 Parents: df6edf1 Author: Anton Vinogradov <[email protected]> Authored: Tue Oct 27 14:06:59 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Tue Oct 27 14:06:59 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/preloader/GridDhtPartitionSupplier.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/d78e4cdb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java index e0e9ce1..f5ae93b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java @@ -217,12 +217,14 @@ class GridDhtPartitionSupplier { try { SupplyContext sctx = scMap.remove(scId); + // Context will be cleaned in case topology changed. if (sctx != null && (!d.topologyVersion().equals(sctx.topVer) || d.updateSequence() != sctx.updateSeq)) { clearContext(sctx, log); sctx = null; } + // Initial demand request should contain partitions list. if (sctx == null && d.partitions() == null) return;
