Repository: ignite Updated Branches: refs/heads/ignite-10291 10f5f9e32 -> 8a2a8610a
Minors. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b35634bf Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b35634bf Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b35634bf Branch: refs/heads/ignite-10291 Commit: b35634bf58a3deb903f4ba9590c36eaa16d8fa4a Parents: 10f5f9e Author: devozerov <[email protected]> Authored: Wed Nov 28 12:51:32 2018 +0300 Committer: devozerov <[email protected]> Committed: Wed Nov 28 12:51:32 2018 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/query/GridQueryProcessor.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/b35634bf/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java index d3f2930..95ff3d5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/GridQueryProcessor.java @@ -1764,9 +1764,10 @@ public class GridQueryProcessor extends GridProcessorAdapter { GridCompoundFuture<Object, ?> fut = new GridCompoundFuture<Object, Object>(); for (Map.Entry<QueryTypeIdKey, QueryTypeDescriptorImpl> e : types.entrySet()) { - if (cacheIds.contains(CU.cacheId(e.getKey().cacheName())) && - processedCacheNames.add(e.getKey().cacheName())) - fut.add(rebuildIndexesFromHash(e.getKey().cacheName(), e.getValue())); + String cacheName = e.getKey().cacheName(); + + if (cacheIds.contains(CU.cacheId(cacheName)) && processedCacheNames.add(cacheName)) + fut.add(rebuildIndexesFromHash(cacheName, e.getValue())); } fut.markInitialized();
