diff --git oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/DataStoreTestBase.java oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/DataStoreTestBase.java index 59a725c..f6e0200 100644 --- oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/DataStoreTestBase.java +++ oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/DataStoreTestBase.java @@ -19,6 +19,7 @@ package org.apache.jackrabbit.oak.segment.standby; +import static java.util.concurrent.Executors.newSingleThreadScheduledExecutor; import static org.junit.Assert.assertArrayEquals; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; @@ -29,6 +30,7 @@ import java.io.ByteArrayInputStream; import java.io.File; import java.io.IOException; import java.util.Random; +import java.util.concurrent.ScheduledExecutorService; import org.apache.jackrabbit.core.data.FileDataStore; import org.apache.jackrabbit.oak.api.Blob; @@ -46,6 +48,7 @@ import org.apache.jackrabbit.oak.spi.commit.CommitInfo; import org.apache.jackrabbit.oak.spi.commit.EmptyHook; import org.apache.jackrabbit.oak.spi.state.NodeBuilder; import org.apache.jackrabbit.oak.spi.state.NodeStore; +import org.apache.jackrabbit.oak.stats.DefaultStatisticsProvider; import org.junit.Before; import org.junit.Ignore; import org.junit.Test; @@ -62,6 +65,7 @@ public class DataStoreTestBase extends TestBase { } protected FileStore setupFileDataStore(File d, String path) throws Exception { + ScheduledExecutorService executor = newSingleThreadScheduledExecutor(); FileDataStore fds = new FileDataStore(); fds.setMinRecordLength(4092); fds.init(path); @@ -74,6 +78,7 @@ public class DataStoreTestBase extends TestBase { .withStringCacheSize(0) .withTemplateCacheSize(0) .withBlobStore(blobStore) + .withStatisticsProvider(new DefaultStatisticsProvider(executor)) .build(); } diff --git oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/TestBase.java oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/TestBase.java index a0d9616..f7696ee 100644 --- oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/TestBase.java +++ oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/TestBase.java @@ -25,12 +25,15 @@ import static org.junit.Assume.assumeTrue; import java.io.File; import java.io.IOException; +import java.util.concurrent.Executors; +import java.util.concurrent.ScheduledExecutorService; import org.apache.commons.io.FileUtils; import org.apache.commons.lang3.SystemUtils; import org.apache.jackrabbit.oak.commons.CIHelper; import org.apache.jackrabbit.oak.segment.file.FileStore; import org.apache.jackrabbit.oak.segment.standby.client.StandbyClient; +import org.apache.jackrabbit.oak.stats.DefaultStatisticsProvider; import org.junit.BeforeClass; public class TestBase { @@ -76,6 +79,7 @@ public class TestBase { } private static FileStore newFileStore(File directory) throws Exception { + ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor(); return fileStoreBuilder(directory) .withMaxFileSize(1) .withMemoryMapping(false) @@ -83,6 +87,7 @@ public class TestBase { .withSegmentCacheSize(0) .withStringCacheSize(0) .withTemplateCacheSize(0) + .withStatisticsProvider(new DefaultStatisticsProvider(executor)) .build(); }