You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by av...@apache.org on 2016/11/15 13:25:39 UTC
[4/4] 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/3fc434ed
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3fc434ed
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3fc434ed
Branch: refs/heads/ignite-4225
Commit: 3fc434ed4d5f7c5f2e6b8c73f350356c786eb567
Parents: 6e36a79
Author: Anton Vinogradov <av...@apache.org>
Authored: Tue Nov 15 16:21:38 2016 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Tue Nov 15 16:21:38 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/3fc434ed/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();