You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by te...@apache.org on 2011/07/07 12:57:34 UTC
svn commit: r1143757 -
/hbase/trunk/src/test/java/org/apache/hadoop/hbase/client/TestMultiParallel.java
Author: tedyu
Date: Thu Jul 7 10:57:34 2011
New Revision: 1143757
URL: http://svn.apache.org/viewvc?rev=1143757&view=rev
Log:
Added timeouts for TestMultiParallel
Modified:
hbase/trunk/src/test/java/org/apache/hadoop/hbase/client/TestMultiParallel.java
Modified: hbase/trunk/src/test/java/org/apache/hadoop/hbase/client/TestMultiParallel.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/test/java/org/apache/hadoop/hbase/client/TestMultiParallel.java?rev=1143757&r1=1143756&r2=1143757&view=diff
==============================================================================
--- hbase/trunk/src/test/java/org/apache/hadoop/hbase/client/TestMultiParallel.java (original)
+++ hbase/trunk/src/test/java/org/apache/hadoop/hbase/client/TestMultiParallel.java Thu Jul 7 10:57:34 2011
@@ -116,7 +116,8 @@ public class TestMultiParallel {
* @throws NoSuchFieldException
* @throws SecurityException
*/
- @Test public void testActiveThreadsCount() throws Exception{
+ @Test(timeout=300000)
+ public void testActiveThreadsCount() throws Exception{
HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE);
List<Row> puts = constructPutRequests(); // creates a Put for every region
table.batch(puts);
@@ -126,7 +127,8 @@ public class TestMultiParallel {
assertEquals(slaves, tExecutor.getLargestPoolSize());
}
- @Test public void testBatchWithGet() throws Exception {
+ @Test(timeout=300000)
+ public void testBatchWithGet() throws Exception {
LOG.info("test=testBatchWithGet");
HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE);
@@ -199,12 +201,14 @@ public class TestMultiParallel {
*
* @throws Exception
*/
- @Test public void testFlushCommitsWithAbort() throws Exception {
+ @Test (timeout=300000)
+ public void testFlushCommitsWithAbort() throws Exception {
LOG.info("test=testFlushCommitsWithAbort");
doTestFlushCommits(true);
}
- @Test public void testFlushCommitsNoAbort() throws Exception {
+ @Test (timeout=300000)
+ public void testFlushCommitsNoAbort() throws Exception {
LOG.info("test=testFlushCommitsNoAbort");
doTestFlushCommits(false);
}
@@ -257,7 +261,8 @@ public class TestMultiParallel {
LOG.info("done");
}
- @Test public void testBatchWithPut() throws Exception {
+ @Test (timeout=300000)
+ public void testBatchWithPut() throws Exception {
LOG.info("test=testBatchWithPut");
HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE);
@@ -278,7 +283,8 @@ public class TestMultiParallel {
validateLoadedData(table);
}
- @Test public void testBatchWithDelete() throws Exception {
+ @Test(timeout=300000)
+ public void testBatchWithDelete() throws Exception {
LOG.info("test=testBatchWithDelete");
HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE);
@@ -306,7 +312,8 @@ public class TestMultiParallel {
}
- @Test public void testHTableDeleteWithList() throws Exception {
+ @Test(timeout=300000)
+ public void testHTableDeleteWithList() throws Exception {
LOG.info("test=testHTableDeleteWithList");
HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE);
@@ -334,7 +341,8 @@ public class TestMultiParallel {
}
- @Test public void testBatchWithManyColsInOneRowGetAndPut() throws Exception {
+ @Test(timeout=300000)
+ public void testBatchWithManyColsInOneRowGetAndPut() throws Exception {
LOG.info("test=testBatchWithManyColsInOneRowGetAndPut");
HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE);
@@ -370,7 +378,8 @@ public class TestMultiParallel {
}
- @Test public void testBatchWithMixedActions() throws Exception {
+ @Test(timeout=300000)
+ public void testBatchWithMixedActions() throws Exception {
LOG.info("test=testBatchWithMixedActions");
HTable table = new HTable(UTIL.getConfiguration(), TEST_TABLE);