5578
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1e154fb2 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1e154fb2 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1e154fb2 Branch: refs/heads/ignite-5578 Commit: 1e154fb25a8ad554011551c20c3d1273b3e439c3 Parents: df73c30 Author: sboikov <[email protected]> Authored: Thu Jul 27 12:16:55 2017 +0300 Committer: sboikov <[email protected]> Committed: Thu Jul 27 12:16:55 2017 +0300 ---------------------------------------------------------------------- .../distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/1e154fb2/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java index 88da6b1..5888f77 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java @@ -930,6 +930,8 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte * @throws IgniteCheckedException If failed. */ private void distributedExchange2() throws IgniteCheckedException { + waitPartitionRelease(); + if (state == ExchangeLocalState.CRD) { if (remaining.isEmpty()) onAllReceived();
