ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a.@apache.org
Subject [4/4] ignite git commit: IGNITE-4225 DataStreamer can hang on changing topology
Date Tue, 15 Nov 2016 13:25:39 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/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();
 


Mime
View raw message