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 2018/11/20 18:04:01 UTC
[08/50] [abbrv] ignite git commit: IGNITE-10156 Fixed invalid
conversion of DynamicCacheDescriptor to StoredCacheData - Fixes #5332.
IGNITE-10156 Fixed invalid conversion of DynamicCacheDescriptor to StoredCacheData - Fixes #5332.
Signed-off-by: Alexey Goncharuk <al...@gmail.com>
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2311afd3
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2311afd3
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2311afd3
Branch: refs/heads/ignite-9720
Commit: 2311afd32e2afc0aa0ebc350e6a3d964206b477f
Parents: 34c059a
Author: Anton Kalashnikov <ka...@yandex.ru>
Authored: Fri Nov 16 19:11:16 2018 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Fri Nov 16 19:11:16 2018 +0300
----------------------------------------------------------------------
.../apache/ignite/internal/processors/cache/CachesRegistry.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/2311afd3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CachesRegistry.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CachesRegistry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CachesRegistry.java
index fe55f97..d37f69c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CachesRegistry.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CachesRegistry.java
@@ -280,7 +280,7 @@ public class CachesRegistry {
*/
private IgniteInternalFuture<?> persistCacheConfigurations(List<DynamicCacheDescriptor> cacheDescriptors) {
List<StoredCacheData> cacheConfigsToPersist = cacheDescriptors.stream()
- .map(cacheDesc -> new StoredCacheData(cacheDesc.cacheConfiguration()).sql(cacheDesc.sql()))
+ .map(DynamicCacheDescriptor::toStoredData)
.collect(Collectors.toList());
// Pre-create cache work directories if they don't exist.