Repository: incubator-ignite Updated Branches: refs/heads/ignite-784 933b3dca6 -> b0a32a1b6
# ignite-784 Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/b0a32a1b Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/b0a32a1b Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/b0a32a1b Branch: refs/heads/ignite-784 Commit: b0a32a1b6c7d04916234ae0b5b68a652a5f87dd5 Parents: 933b3dc Author: sboikov <sboi...@gridgain.com> Authored: Thu Apr 23 11:53:19 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Thu Apr 23 11:53:19 2015 +0300 ---------------------------------------------------------------------- .../processors/cache/distributed/near/GridNearCacheEntry.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b0a32a1b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearCacheEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearCacheEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearCacheEntry.java index 819024c..146873b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearCacheEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearCacheEntry.java @@ -171,9 +171,9 @@ public class GridNearCacheEntry extends GridDistributedCacheEntry { ClusterNode primaryNode = cctx.affinity().primary(key, topVer); if (primaryNode == null) - return false; - - recordNodeId(cctx.affinity().primary(key, topVer).id(), topVer); + this.topVer = -1L; + else + recordNodeId(primaryNode.id(), topVer); dhtVer = e.isNew() || e.isDeleted() ? null : e.version();
