You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2018/11/20 14:54:52 UTC

[09/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-10044
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.