ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject ignite git commit: IGNITE-6488 Added info message for index rebuild
Date Fri, 22 Sep 2017 15:15:36 GMT
Repository: ignite
Updated Branches:
  refs/heads/master 54a00fcf1 -> 7ecdd7dcf


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/master
Commit: 7ecdd7dcf8e8c7334f3003bbf47d9318a0b2afab
Parents: 54a00fc
Author: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Authored: Fri Sep 22 18:15:26 2017 +0300
Committer: Alexey Goncharuk <alexey.goncharuk@gmail.com>
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."));


Mime
View raw message