Repository: ignite Updated Branches: refs/heads/ignite-9273 3c3fe20c6 -> 74991e14f
IGNITE-9273 Do not touch topology for LOCAL cache Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/74991e14 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/74991e14 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/74991e14 Branch: refs/heads/ignite-9273 Commit: 74991e14f6da5c3de47e0f8af80870e683310877 Parents: 3c3fe20 Author: Alexey Goncharuk <alexey.goncha...@gmail.com> Authored: Wed Aug 22 18:07:24 2018 +0300 Committer: Alexey Goncharuk <alexey.goncha...@gmail.com> Committed: Wed Aug 22 18:07:24 2018 +0300 ---------------------------------------------------------------------- .../internal/processors/cache/IgniteCacheOffheapManagerImpl.java | 2 +- .../cache/persistence/GridCacheDatabaseSharedManager.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/74991e14/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java index 5482b3a..17aa9e6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheOffheapManagerImpl.java @@ -252,7 +252,7 @@ public class IgniteCacheOffheapManagerImpl implements IgniteCacheOffheapManager * @param part Partition. * @return Data store for given entry. */ - public CacheDataStore dataStore(GridDhtLocalPartition part) { + @Override public CacheDataStore dataStore(GridDhtLocalPartition part) { if (grp.isLocal()) return locCacheDataStore; else { http://git-wip-us.apache.org/repos/asf/ignite/blob/74991e14/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java index fa1d4c3..f73fc78 100755 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java @@ -2458,7 +2458,7 @@ public class GridCacheDatabaseSharedManager extends IgniteCacheDatabaseSharedMan if (partId == -1) partId = cacheCtx.affinity().partition(dataEntry.key()); - GridDhtLocalPartition locPart = cacheCtx.topology().forceCreatePartition(partId); + GridDhtLocalPartition locPart = cacheCtx.isLocal() ? null : cacheCtx.topology().forceCreatePartition(partId); switch (dataEntry.op()) { case CREATE:
