ignite-647 Fixed issues with dynamic cache start when fair affinity is used


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/6d6be6b4
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6d6be6b4
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6d6be6b4

Branch: refs/heads/ignite-1537
Commit: 6d6be6b4c650eb22b89c1a2d3e77e018ec4b2c51
Parents: 185c28a
Author: sboikov <sboi...@gridgain.com>
Authored: Thu Dec 24 09:04:00 2015 +0300
Committer: sboikov <sboi...@gridgain.com>
Committed: Thu Dec 24 09:04:00 2015 +0300

----------------------------------------------------------------------
 .../processors/cache/binary/CacheObjectBinaryProcessorImpl.java   | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/6d6be6b4/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/CacheObjectBinaryProcessorImpl.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/CacheObjectBinaryProcessorImpl.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/CacheObjectBinaryProcessorImpl.java
index 7493a43..2209ec9 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/CacheObjectBinaryProcessorImpl.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/CacheObjectBinaryProcessorImpl.java
@@ -491,6 +491,9 @@ public class CacheObjectBinaryProcessorImpl extends 
IgniteCacheObjectProcessorIm
 
             AffinityTopologyVersion topVer = 
ctx.cache().context().lockedTopologyVersion(null);
 
+            if (topVer == null)
+                topVer = 
ctx.cache().context().exchange().readyAffinityVersion();
+
             BinaryObjectException err = metaDataCache.invoke(topVer, key, new 
MetadataProcessor(mergedMeta));
 
             if (err != null)

Reply via email to