Repository: ignite Updated Branches: refs/heads/ignite-5578 68e4e4510 -> a6f06d958
http://git-wip-us.apache.org/repos/asf/ignite/blob/a6f06d95/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/WaitMapExchangeFinishCallable.java ---------------------------------------------------------------------- diff --git a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/WaitMapExchangeFinishCallable.java b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/WaitMapExchangeFinishCallable.java index 83c50bd..ebd2e43 100644 --- a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/WaitMapExchangeFinishCallable.java +++ b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/WaitMapExchangeFinishCallable.java @@ -52,7 +52,7 @@ public class WaitMapExchangeFinishCallable implements IgniteCallable<Void> { for (;;) { boolean success = true; - if (top.topologyVersion().topologyVersion() == ignite.cluster().topologyVersion()) { + if (top.readyTopologyVersion().topologyVersion() == ignite.cluster().topologyVersion()) { for (Map.Entry<UUID, GridDhtPartitionMap> e : top.partitionMap(true).entrySet()) { for (Map.Entry<Integer, GridDhtPartitionState> p : e.getValue().entrySet()) { if (p.getValue() != GridDhtPartitionState.OWNING) { @@ -70,7 +70,7 @@ public class WaitMapExchangeFinishCallable implements IgniteCallable<Void> { } } else { - BenchmarkUtils.println("Topology version is different [cache=" + top.topologyVersion() + + BenchmarkUtils.println("Topology version is different [cache=" + top.readyTopologyVersion() + ", cluster=" + ignite.cluster().topologyVersion() + ']'); success = false;