ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [06/10] ignite git commit: IGNITE-4225 DataStreamer can hang on changing topology
Date Tue, 22 Nov 2016 10:49:09 GMT
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();
 


Mime
View raw message