IGNITE-10156 Fixed invalid conversion of DynamicCacheDescriptor to 
StoredCacheData - Fixes #5332.

Signed-off-by: Alexey Goncharuk <alexey.goncha...@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 <kaa....@yandex.ru>
Authored: Fri Nov 16 19:11:16 2018 +0300
Committer: Alexey Goncharuk <alexey.goncha...@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.

Reply via email to