ignite-gg-12329 do not update partition map, in case cluster transitioning to inactive state.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/9b77b700 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/9b77b700 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/9b77b700 Branch: refs/heads/ignite-2.1.2-exchange Commit: 9b77b700f0980db94f358fbfff3fc7ff7d18dd6b Parents: 7c515ee Author: Dmitriy Govorukhin <[email protected]> Authored: Wed Jun 21 14:45:02 2017 +0300 Committer: Dmitriy Govorukhin <[email protected]> Committed: Wed Jun 21 14:45:02 2017 +0300 ---------------------------------------------------------------------- .../dht/preloader/GridDhtPartitionsExchangeFuture.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/9b77b700/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 230a25c..6cc269a 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 @@ -1444,7 +1444,9 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte if (updateSingleMap) { try { - updatePartitionSingleMap(node, msg); + // Do not update partition map, in case cluster transitioning to inactive state. + if (!exchangeOnChangeGlobalState || exchActions.newClusterState() != ClusterState.INACTIVE) + updatePartitionSingleMap(node, msg); } finally { synchronized (this) {
