Repository: ignite Updated Branches: refs/heads/ignite-1093-2 5de124cd9 -> de424c1b0
Test Failed Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/de424c1b Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/de424c1b Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/de424c1b Branch: refs/heads/ignite-1093-2 Commit: de424c1b0105df5fce2a9113930eac8900621abf Parents: 5de124c Author: Anton Vinogradov <[email protected]> Authored: Mon Oct 5 18:45:51 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Mon Oct 5 18:45:51 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/preloader/GridDhtPartitionDemander.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/de424c1b/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 56a9c9b..a170bc6 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 @@ -199,8 +199,7 @@ public class GridDhtPartitionDemander { private boolean topologyChanged(SyncFuture fut) { return !cctx.affinity().affinityTopologyVersion().equals(fut.topologyVersion()) || // Topology already changed. - fut != syncFut || // Same topology, but dummy exchange forced because of missing partitions. - cctx.shared().exchange().hasPendingExchange(); // New topology pending. + fut != syncFut; // Same topology, but dummy exchange forced because of missing partitions. } /**
