Repository: hbase Updated Branches: refs/heads/branch-1 966aeb06a -> 64135da82
HBASE-16515 AsyncProcess has incorrent count of tasks if the backoff policy is enabled - addendum fixes timeout of TestAsyncProcess#testSubmitRandomSizeRequest (Chiaping Tsai) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/64135da8 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/64135da8 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/64135da8 Branch: refs/heads/branch-1 Commit: 64135da8244c4b42b4dd2bfeab0311869d2d31cf Parents: 966aeb0 Author: tedyu <[email protected]> Authored: Wed Aug 31 02:05:45 2016 -0700 Committer: tedyu <[email protected]> Committed: Wed Aug 31 02:05:45 2016 -0700 ---------------------------------------------------------------------- .../apache/hadoop/hbase/client/TestAsyncProcess.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/64135da8/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestAsyncProcess.java ---------------------------------------------------------------------- diff --git a/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestAsyncProcess.java b/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestAsyncProcess.java index bf50ee2..ac39654 100644 --- a/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestAsyncProcess.java +++ b/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestAsyncProcess.java @@ -570,12 +570,12 @@ public class TestAsyncProcess { 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
