IGNITE-6488 Added info message for index rebuild
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7ecdd7dc Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7ecdd7dc Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7ecdd7dc Branch: refs/heads/ignite-3478 Commit: 7ecdd7dcf8e8c7334f3003bbf47d9318a0b2afab Parents: 54a00fc Author: Alexey Goncharuk <[email protected]> Authored: Fri Sep 22 18:15:26 2017 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Fri Sep 22 18:15:26 2017 +0300 ---------------------------------------------------------------------- .../cache/persistence/GridCacheDatabaseSharedManager.java | 5 ++++- .../ignite/internal/processors/query/GridQueryProcessor.java | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/7ecdd7dc/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java index 426e27f..9f1ccb4 100755 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheDatabaseSharedManager.java @@ -860,7 +860,7 @@ public class GridCacheDatabaseSharedManager extends IgniteCacheDatabaseSharedMan restoreState(); if (cctx.kernalContext().query().moduleEnabled()) { - for (GridCacheContext cacheCtx : (Collection<GridCacheContext>)cctx.cacheContexts()) { + for (final GridCacheContext cacheCtx : (Collection<GridCacheContext>)cctx.cacheContexts()) { if (cacheCtx.startTopologyVersion().equals(fut.initialVersion()) && !cctx.pageStore().hasIndexStore(cacheCtx.groupId()) && cacheCtx.affinityNode()) { final int cacheId = cacheCtx.cacheId(); @@ -873,6 +873,9 @@ public class GridCacheDatabaseSharedManager extends IgniteCacheDatabaseSharedMan rebuildFut.listen(new CI1<IgniteInternalFuture>() { @Override public void apply(IgniteInternalFuture igniteInternalFut) { idxRebuildFuts.remove(cacheId, rebuildFut); + + log().info("Finished indexes rebuilding for cache: [name=" + cacheCtx.config().getName() + + ", grpName=" + cacheCtx.config().getGroupName()); } }); } http://git-wip-us.apache.org/repos/asf/ignite/blob/7ecdd7dc/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 51d3411..2a13b25 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 @@ -1627,7 +1627,7 @@ public class GridQueryProcessor extends GridProcessorAdapter { * @param desc Type descriptor. * @return Future that will be completed when rebuilding of all indexes is finished. */ -private IgniteInternalFuture<Object> rebuildIndexesFromHash(@Nullable final String cacheName, + private IgniteInternalFuture<Object> rebuildIndexesFromHash(@Nullable final String cacheName, @Nullable final QueryTypeDescriptorImpl desc) { if (idx == null) return new GridFinishedFuture<>(new IgniteCheckedException("Indexing is disabled."));
