diff --git hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestAsyncProcess.java hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestAsyncProcess.java index 00f5232..5c2eeeb 100644 --- hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestAsyncProcess.java +++ hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestAsyncProcess.java @@ -548,16 +548,15 @@ public class TestAsyncProcess { doSubmitRequest(maxHeapSizePerRequest, putsHeapSize); } - @Test(timeout=300000) + @Test public void testSubmitRandomSizeRequest() throws Exception { Random rn = new Random(); final long limit = 10 * 1024 * 1024; - for (int count = 0; count != 2; ++count) { - long maxHeapSizePerRequest = Math.max(1, (Math.abs(rn.nextLong()) % limit)); - long putsHeapSize = Math.max(1, (Math.abs(rn.nextLong()) % limit)); - LOG.info("[testSubmitRandomSizeRequest] maxHeapSizePerRequest=" + maxHeapSizePerRequest + ", putsHeapSize=" + putsHeapSize); - doSubmitRequest(maxHeapSizePerRequest, putsHeapSize); - } + final int requestCount = 1 + (int) (rn.nextDouble() * 3); + long putsHeapSize = Math.abs(rn.nextLong()) % limit; + long maxHeapSizePerRequest = putsHeapSize / requestCount; + LOG.info("[testSubmitRandomSizeRequest] maxHeapSizePerRequest=" + maxHeapSizePerRequest + ", putsHeapSize=" + putsHeapSize); + doSubmitRequest(maxHeapSizePerRequest, putsHeapSize); } @Test @@ -567,7 +566,7 @@ public class TestAsyncProcess { doSubmitRequest(maxHeapSizePerRequest, putsHeapSize); } - @Test(timeout=120000) + @Test public void testSubmitLargeRequest() throws Exception { long maxHeapSizePerRequest = 2 * 1024 * 1024; long putsHeapSize = maxHeapSizePerRequest * 2;