diff --git a/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java b/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java index 3e224f5..1bb64ab 100644 --- a/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java +++ b/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/index/AsyncIndexUpdate.java @@ -661,6 +661,8 @@ public class AsyncIndexUpdate implements Runnable, Closeable { } keep.add(cp); keep.addAll(indexStats.tempCps); + // Additional logging needed for + log.info("Getting checkpoint info for {}", cp); Map info = store.checkpointInfo(cp); String value = info.get("created"); if (value != null) { @@ -685,6 +687,9 @@ public class AsyncIndexUpdate implements Runnable, Closeable { } } } + } else { + // Additional logging needed for + log.info("Checkpoint Info : '{}' for the checkpoint - {} ; keep -- {}", info, cp, keep); } } diff --git a/oak-store-composite/src/main/java/org/apache/jackrabbit/oak/composite/CompositeNodeStore.java b/oak-store-composite/src/main/java/org/apache/jackrabbit/oak/composite/CompositeNodeStore.java index 2a4a330..6a1db37 100644 --- a/oak-store-composite/src/main/java/org/apache/jackrabbit/oak/composite/CompositeNodeStore.java +++ b/oak-store-composite/src/main/java/org/apache/jackrabbit/oak/composite/CompositeNodeStore.java @@ -51,6 +51,7 @@ import java.util.List; import java.util.Map; import java.util.Set; import java.util.stream.Collectors; +import java.util.stream.Stream; import static com.google.common.base.Preconditions.checkArgument; import static com.google.common.base.Preconditions.checkNotNull; @@ -244,6 +245,13 @@ public class CompositeNodeStore implements NodeStore, Observable { public Map checkpointInfo(String checkpoint) { if (!checkpointExists(ctx.getGlobalStore().getNodeStore(), checkpoint)) { LOG.warn("Checkpoint {} doesn't exist. Debug info:\n{}", checkpoint, checkpointDebugInfo()); + // Additional logging needed for + StackTraceElement[] stackTrace = Thread.currentThread().getStackTrace(); + if (stackTrace != null) { + StringBuilder threadDetails = new StringBuilder(); + Stream.of(stackTrace).forEach(threadDetails::append); + LOG.warn(threadDetails.toString()); + } return Collections.emptyMap(); } return copyOf(filterKeys(ctx.getGlobalStore().getNodeStore().checkpointInfo(checkpoint), new Predicate() {