You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/11/22 10:49:09 UTC
[06/10] ignite git commit: IGNITE-4225 DataStreamer can hang on
changing topology
IGNITE-4225 DataStreamer can hang on changing topology
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d15eba4b
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d15eba4b
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d15eba4b
Branch: refs/heads/ignite-4259
Commit: d15eba4becf7515b512c1032b193ce75e1589177
Parents: d32fa21
Author: Anton Vinogradov <av...@apache.org>
Authored: Tue Nov 22 11:56:20 2016 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Tue Nov 22 11:56:20 2016 +0300
----------------------------------------------------------------------
.../ignite/internal/processors/datastreamer/DataStreamerImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/d15eba4b/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 @@ public class DataStreamerImpl<K, V> implements IgniteDataStreamer<K, V>, Delayed
AffinityTopologyVersion topVer = cctx.isLocal() ?
cctx.affinity().affinityTopologyVersion() :
- cctx.topology().topologyVersion();
+ cctx.shared().exchange().readyAffinityVersion();
GridCacheVersion ver = cctx.versions().isolatedStreamerVersion();