You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/12/24 07:10:24 UTC
[09/11] ignite git commit: ignite-647 Fixed issues with dynamic cache
start when fair affinity is used
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 <sb...@gridgain.com>
Authored: Thu Dec 24 09:04:00 2015 +0300
Committer: sboikov <sb...@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)