You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ra...@apache.org on 2017/05/26 11:45:43 UTC
hbase git commit: HBASE-17777 TestMemstoreLAB#testLABThreading runs
too long for a small test (Ram)
Repository: hbase
Updated Branches:
refs/heads/master b076b8e79 -> 8b5c161cb
HBASE-17777 TestMemstoreLAB#testLABThreading runs too long for a small
test (Ram)
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/8b5c161c
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8b5c161c
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8b5c161c
Branch: refs/heads/master
Commit: 8b5c161cbf0cab4eb250827e20a12acee00b400d
Parents: b076b8e
Author: Ramkrishna <ra...@intel.com>
Authored: Fri May 26 17:15:04 2017 +0530
Committer: Ramkrishna <ra...@intel.com>
Committed: Fri May 26 17:15:04 2017 +0530
----------------------------------------------------------------------
.../hbase/regionserver/TestMemStoreLAB.java | 22 +++++++++++++-------
1 file changed, 15 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/8b5c161c/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMemStoreLAB.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMemStoreLAB.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMemStoreLAB.java
index 7def2a7..e27d7c2 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMemStoreLAB.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMemStoreLAB.java
@@ -40,6 +40,7 @@ import org.apache.hadoop.hbase.io.util.MemorySizeUtil;
import org.apache.hadoop.hbase.testclassification.RegionServerTests;
import org.apache.hadoop.hbase.testclassification.SmallTests;
import org.apache.hadoop.hbase.util.Bytes;
+import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
@@ -61,10 +62,17 @@ public class TestMemStoreLAB {
@BeforeClass
public static void setUpBeforeClass() throws Exception {
- long globalMemStoreLimit = (long) (ManagementFactory.getMemoryMXBean().getHeapMemoryUsage()
- .getMax() * MemorySizeUtil.getGlobalMemStoreHeapPercent(conf, false));
- ChunkCreator.initialize(MemStoreLABImpl.CHUNK_SIZE_DEFAULT, false, globalMemStoreLimit,
- 0.2f, MemStoreLAB.POOL_INITIAL_SIZE_DEFAULT, null);
+ ChunkCreator.initialize(1 * 1024, false, 50*1024000l, 0.2f, MemStoreLAB.POOL_INITIAL_SIZE_DEFAULT,
+ null);
+ }
+
+ @AfterClass
+ public static void tearDownAfterClass() throws Exception {
+ long globalMemStoreLimit =
+ (long) (ManagementFactory.getMemoryMXBean().getHeapMemoryUsage().getMax()
+ * MemorySizeUtil.getGlobalMemStoreHeapPercent(conf, false));
+ ChunkCreator.initialize(MemStoreLABImpl.CHUNK_SIZE_DEFAULT, false, globalMemStoreLimit, 0.2f,
+ MemStoreLAB.POOL_INITIAL_SIZE_DEFAULT, null);
}
/**
@@ -81,7 +89,7 @@ public class TestMemStoreLAB {
// should be reasonable for unit test and also cover wraparound
// behavior
for (int i = 0; i < 100000; i++) {
- int valSize = rand.nextInt(1000);
+ int valSize = rand.nextInt(3);
KeyValue kv = new KeyValue(rk, cf, q, new byte[valSize]);
int size = KeyValueUtil.length(kv);
ByteBufferKeyValue newKv = (ByteBufferKeyValue) mslab.copyCellInto(kv);
@@ -132,7 +140,7 @@ public class TestMemStoreLAB {
private Random r = new Random();
@Override
public void doAnAction() throws Exception {
- int valSize = r.nextInt(1000);
+ int valSize = r.nextInt(3);
KeyValue kv = new KeyValue(rk, cf, q, new byte[valSize]);
int size = KeyValueUtil.length(kv);
ByteBufferKeyValue newCell = (ByteBufferKeyValue) mslab.copyCellInto(kv);
@@ -144,7 +152,7 @@ public class TestMemStoreLAB {
}
ctx.startThreads();
- while (totalAllocated.get() < 50*1024*1024 && ctx.shouldRun()) {
+ while (totalAllocated.get() < 50*1024*1000 && ctx.shouldRun()) {
Thread.sleep(10);
}
ctx.stop();