Repository: ignite Updated Branches: refs/heads/ignite-1093-3 cc3be8704 -> fa4285217
1093 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fa428521 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fa428521 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fa428521 Branch: refs/heads/ignite-1093-3 Commit: fa4285217edd1cc73c942e18625164bcffd79678 Parents: cc3be87 Author: Anton Vinogradov <[email protected]> Authored: Fri Oct 30 18:34:37 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Fri Oct 30 18:34:37 2015 +0300 ---------------------------------------------------------------------- .../distributed/dht/preloader/GridDhtPartitionDemander.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/fa428521/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 ee603e3..0c5ff26 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 @@ -917,7 +917,9 @@ public class GridDhtPartitionDemander { Collection<Integer> parts = remaining.get(nodeId).get2(); if (parts != null) { - parts.remove(p); + boolean removed = parts.remove(p); + + assert removed; if (parts.isEmpty()) { U.log(log, "Completed " + ((remaining.size() == 1 ? "(final) " : "") +
