Repository: ignite Updated Branches: refs/heads/ignite-4424 23b606e8c -> e5f04ccbc
IGNITE-4424 REPLICATED cache isn't synced across nodes Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e5f04ccb Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e5f04ccb Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e5f04ccb Branch: refs/heads/ignite-4424 Commit: e5f04ccbcb28bc9364160c95e32efe4a802acc3e Parents: 23b606e Author: Anton Vinogradov <[email protected]> Authored: Fri Dec 23 12:38:04 2016 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Fri Dec 23 12:38:04 2016 +0300 ---------------------------------------------------------------------- .../distributed/dht/atomic/GridNearAtomicSingleUpdateFuture.java | 4 +--- .../cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java | 2 +- 2 files changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/e5f04ccb/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 0870e5f..3ce1d75 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 @@ -381,7 +381,7 @@ public class GridNearAtomicSingleUpdateFuture extends GridNearAtomicAbstractUpda @Override protected void mapOnTopology() { cache.topology().readLock(); - AffinityTopologyVersion topVer = null; + AffinityTopologyVersion topVer; try { if (cache.topology().stopping()) { @@ -463,8 +463,6 @@ public class GridNearAtomicSingleUpdateFuture extends GridNearAtomicAbstractUpda Exception err = null; GridNearAtomicAbstractUpdateRequest singleReq0 = null; - GridCacheVersion futVer = cctx.versions().next(topVer); - try { singleReq0 = mapSingleUpdate(topVer, futVer, updVer); http://git-wip-us.apache.org/repos/asf/ignite/blob/e5f04ccb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java index a4634ee..0acf351 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java @@ -490,7 +490,7 @@ public class GridNearAtomicUpdateFuture extends GridNearAtomicAbstractUpdateFutu @Override protected void mapOnTopology() { cache.topology().readLock(); - AffinityTopologyVersion topVer = null; + AffinityTopologyVersion topVer; try { if (cache.topology().stopping()) {
