Author: chetanm
Date: Tue Jul 11 09:40:02 2017
New Revision: 1801581
URL: http://svn.apache.org/viewvc?rev=1801581&view=rev
Log:
OAK-6271 - Support for importing index files
Add log message around when index catch is being done
Modified:
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/importer/IndexImporter.java
Modified:
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/importer/IndexImporter.java
URL:
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/importer/IndexImporter.java?rev=1801581&r1=1801580&r2=1801581&view=diff
==============================================================================
---
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/importer/IndexImporter.java
(original)
+++
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/importer/IndexImporter.java
Tue Jul 11 09:40:02 2017
@@ -148,6 +148,9 @@ public class IndexImporter {
NodeState after = nodeStore.retrieve(checkpoint);
checkNotNull(after, "No state found for checkpoint [%s] for lane
[%s]",checkpoint, laneName);
+ log.info("Proceeding to update imported indexes {} to checkpoint
[{}] for lane [{}]",
+ indexInfos, checkpoint, laneName);
+
NodeState before = indexedState;
NodeBuilder builder = nodeStore.getRoot().builder();
@@ -171,6 +174,8 @@ public class IndexImporter {
mergeWithConcurrentCheck(nodeStore, builder);
success = true;
+ log.info("Imported index is updated to repository state at
checkpoint [{}] for " +
+ "indexing lane [{}]", checkpoint, laneName);
} finally {
try {
resumeCurrentIndexing(lockToken);