You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2017/01/23 18:17:23 UTC
[3/5] ignite git commit: ignite-db-x minor update
ignite-db-x minor update
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/742aa94c
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/742aa94c
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/742aa94c
Branch: refs/heads/ignite-3477
Commit: 742aa94c258791ff39365fa55b15d9beb8b1766b
Parents: 26000ca
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Mon Jan 23 19:20:47 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Mon Jan 23 19:20:47 2017 +0300
----------------------------------------------------------------------
.../distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/742aa94c/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java
index 5261e34..f69fb4f 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java
@@ -208,7 +208,7 @@ public class GridNearAtomicSingleUpdateFuture extends GridNearAtomicAbstractUpda
if (!res.futureVersion().equals(futVer))
return;
- if (this.req == null || !this.req.nodeId().equals(nodeId))
+ if ((nodeErr && this.req == null) || !this.req.nodeId().equals(nodeId))
return;
req = this.req;