commit 3fc434ed4d5f7c5f2e6b8c73f350356c786eb567
author Anton Vinogradov <av@apache.org> Tue Nov 15 16:21:38 2016 +0300
committer Anton Vinogradov <av@apache.org> Tue Nov 15 16:21:38 2016 +0300
tree 130581cba469bfdc4c7c393fa6f80e5e68d12f0e
parent 6e36a7950db84913ddfd0d98f5a0b50923d2a29c

IGNITE-4225 DataStreamer can hang on changing topology

modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java

diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
index 443783b..bb9ffdd 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
@@ -1919,7 +1919,7 @@
 
             AffinityTopologyVersion topVer = cctx.isLocal() ?
                 cctx.affinity().affinityTopologyVersion() :
-                cctx.topology().topologyVersion();
+                cctx.shared().exchange().readyAffinityVersion();
 
             GridCacheVersion ver = cctx.versions().isolatedStreamerVersion();