You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2014/02/22 01:32:32 UTC

svn commit: r1570763 - /hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestRowProcessorEndpoint.java

Author: apurtell
Date: Sat Feb 22 00:32:32 2014
New Revision: 1570763

URL: http://svn.apache.org/r1570763
Log:
HBASE-10589 Reduce unnecessary TestRowProcessorEndpoint resource usage

Modified:
    hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestRowProcessorEndpoint.java

Modified: hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestRowProcessorEndpoint.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestRowProcessorEndpoint.java?rev=1570763&r1=1570762&r2=1570763&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestRowProcessorEndpoint.java (original)
+++ hbase/trunk/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestRowProcessorEndpoint.java Sat Feb 22 00:32:32 2014
@@ -173,7 +173,7 @@ public class TestRowProcessorEndpoint {
   public void testReadModifyWrite() throws Throwable {
     prepareTestData();
     failures.set(0);
-    int numThreads = 1000;
+    int numThreads = 100;
     concurrentExec(new IncrementRunner(), numThreads);
     Get get = new Get(ROW);
     LOG.debug("row keyvalues:" + stringifyKvs(table.get(get).listCells()));
@@ -234,7 +234,7 @@ public class TestRowProcessorEndpoint {
   public void testMultipleRows() throws Throwable {
     prepareTestData();
     failures.set(0);
-    int numThreads = 1000;
+    int numThreads = 100;
     concurrentExec(new SwapRowsRunner(), numThreads);
     LOG.debug("row keyvalues:" +
               stringifyKvs(table.get(new Get(ROW)).listCells()));