commit | 3fc434ed4d5f7c5f2e6b8c73f350356c786eb567 | [log] [tgz] |
---|---|---|
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 [diff] |
IGNITE-4225 DataStreamer can hang on changing topology
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();