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;

Reply via email to