Author: alexparvulescu Date: Thu Jun 23 14:43:04 2016 New Revision: 1749907
URL: http://svn.apache.org/viewvc?rev=1749907&view=rev Log: OAK-4493 Offline compaction persisted mode - fix for segment-tar Modified: jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/Compactor.java Modified: jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/Compactor.java URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/Compactor.java?rev=1749907&r1=1749906&r2=1749907&view=diff ============================================================================== --- jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/Compactor.java (original) +++ jackrabbit/oak/trunk/oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/Compactor.java Thu Jun 23 14:43:04 2016 @@ -57,6 +57,14 @@ public class Compactor { /** Logger instance */ private static final Logger log = LoggerFactory.getLogger(Compactor.class); + private static boolean eagerFlush = Boolean.getBoolean("oak.compaction.eagerFlush"); + + static { + if (eagerFlush) { + log.debug("Eager flush enabled."); + } + } + private final SegmentReader reader; private final BlobStore blobStore; @@ -234,7 +242,12 @@ public class Compactor { progress.onNode(); try { - NodeBuilder child = EMPTY_NODE.builder(); + NodeBuilder child; + if (eagerFlush) { + child = builder.setChildNode(name); + } else { + child = EMPTY_NODE.builder(); + } boolean success = new CompactDiff(child, path, name).diff( EMPTY_NODE, after); if (success) {
