Repository: ignite Updated Branches: refs/heads/ignite-80-2 5a110a1d7 -> 04889cd72
ignite-80 Fixed dynamic cache start future completion Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/04889cd7 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/04889cd7 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/04889cd7 Branch: refs/heads/ignite-80-2 Commit: 04889cd724c9ca5975429e6a119b2b6d9e689ca2 Parents: 5a110a1 Author: sboikov <[email protected]> Authored: Mon Sep 28 10:31:02 2015 +0300 Committer: sboikov <[email protected]> Committed: Mon Sep 28 10:31:02 2015 +0300 ---------------------------------------------------------------------- .../processors/datastructures/DataStructuresProcessor.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/04889cd7/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java index 17f5f8e..ef2c543 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java @@ -883,7 +883,9 @@ public final class DataStructuresProcessor extends GridProcessorAdapter { * @throws IgniteCheckedException If failed. */ private String compatibleConfiguration(CollectionConfiguration cfg) throws IgniteCheckedException { - List<CacheCollectionInfo> caches = utilityDataCache.localPeek(DATA_STRUCTURES_CACHE_KEY, null, null); + List<CacheCollectionInfo> caches = utilityDataCache.context().affinityNode() ? + utilityDataCache.localPeek(DATA_STRUCTURES_CACHE_KEY, null, null) : + utilityDataCache.get(DATA_STRUCTURES_CACHE_KEY); String cacheName = findCompatibleConfiguration(cfg, caches);
