Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-10589 Reduce unnecessary TestRowProcessorEndpoint resource usage 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1570763 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Andrew Kyle Purtell 2014-02-22 00:32:32 +00:00
parent 0039de35c8
commit 65e7b7e2e1
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestRowProcessorEndpoint.java
View File

@ -173,7 +173,7 @@ public class TestRowProcessorEndpoint {
public void testReadModifyWrite() throws Throwable { public void testReadModifyWrite() throws Throwable {
prepareTestData(); prepareTestData();
failures.set(0); failures.set(0);
int numThreads = 1000; int numThreads = 100;
concurrentExec(new IncrementRunner(), numThreads); concurrentExec(new IncrementRunner(), numThreads);
Get get = new Get(ROW); Get get = new Get(ROW);
LOG.debug("row keyvalues:" + stringifyKvs(table.get(get).listCells())); LOG.debug("row keyvalues:" + stringifyKvs(table.get(get).listCells()));
@ -234,7 +234,7 @@ public class TestRowProcessorEndpoint {
public void testMultipleRows() throws Throwable { public void testMultipleRows() throws Throwable {
prepareTestData(); prepareTestData();
failures.set(0); failures.set(0);
int numThreads = 1000; int numThreads = 100;
concurrentExec(new SwapRowsRunner(), numThreads); concurrentExec(new SwapRowsRunner(), numThreads);
LOG.debug("row keyvalues:" + LOG.debug("row keyvalues:" +
stringifyKvs(table.get(new Get(ROW)).listCells())); stringifyKvs(table.get(new Get(ROW)).listCells()));