.../src/main/java/org/apache/hadoop/hbase/util/ByteBufferArray.java | 1 + .../src/test/java/org/apache/hadoop/hbase/io/hfile/TestCacheConfig.java | 1 + 2 files changed, 2 insertions(+) diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/util/ByteBufferArray.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/util/ByteBufferArray.java index 60f8c79..9670743 100644 --- a/hbase-common/src/main/java/org/apache/hadoop/hbase/util/ByteBufferArray.java +++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/util/ByteBufferArray.java @@ -78,6 +78,7 @@ public final class ByteBufferArray { private void createBuffers(boolean directByteBuffer, ByteBufferAllocator allocator) throws IOException { int threadCount = Runtime.getRuntime().availableProcessors(); + LOG.info("The available threadcount is "+threadCount); ExecutorService service = new ThreadPoolExecutor(threadCount, threadCount, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue()); int perThreadCount = Math.round((float) (bufferCount) / threadCount); diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestCacheConfig.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestCacheConfig.java index 3353736..ce49814 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestCacheConfig.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestCacheConfig.java @@ -295,6 +295,7 @@ public class TestCacheConfig { @Test public void testOffHeapBucketCacheConfig() { this.conf.set(HConstants.BUCKET_CACHE_IOENGINE_KEY, "offheap"); + LOG.info("Testing offheap cache"); doBucketCacheConfigTest(); }