You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by li...@apache.org on 2014/04/22 20:18:51 UTC
svn commit: r1589231 -
/hbase/branches/0.89-fb/src/test/java/org/apache/hadoop/hbase/client/TestHTableMultiplexer.java
Author: liyin
Date: Tue Apr 22 18:18:51 2014
New Revision: 1589231
URL: http://svn.apache.org/r1589231
Log:
[Master] Make TestHTableMultiplexer more stable
Author: liyintang
Summary: Make TestHTableMultiplexer more stable
Test Plan: Run through this unit test 10 times
Reviewers: adela, daviddeng, elliott
Reviewed By: elliott
CC: hbase-dev@, elliott
Differential Revision: https://phabricator.fb.com/D1286848
Modified:
hbase/branches/0.89-fb/src/test/java/org/apache/hadoop/hbase/client/TestHTableMultiplexer.java
Modified: hbase/branches/0.89-fb/src/test/java/org/apache/hadoop/hbase/client/TestHTableMultiplexer.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/test/java/org/apache/hadoop/hbase/client/TestHTableMultiplexer.java?rev=1589231&r1=1589230&r2=1589231&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/test/java/org/apache/hadoop/hbase/client/TestHTableMultiplexer.java (original)
+++ hbase/branches/0.89-fb/src/test/java/org/apache/hadoop/hbase/client/TestHTableMultiplexer.java Tue Apr 22 18:18:51 2014
@@ -19,16 +19,7 @@
*/
package org.apache.hadoop.hbase.client;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.Future;
-
import junit.framework.Assert;
-
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.conf.Configuration;
@@ -40,6 +31,14 @@ import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+
public class TestHTableMultiplexer {
final Log LOG = LogFactory.getLog(getClass());
@@ -68,7 +67,7 @@ public class TestHTableMultiplexer {
TEST_UTIL.shutdownMiniCluster();
}
- @Test
+ @Test(timeout = 300000)
public void testHTableMultiplexer() throws Exception {
byte[] TABLE = Bytes.toBytes("testHTableMultiplexer");
final int NUM_REGIONS = 10;
@@ -127,7 +126,7 @@ public class TestHTableMultiplexer {
}
private void verifyAllBufferedPutsHasFlushed(HTableMultiplexerStatus status) {
- int retries = 5;
+ int retries = 100; // max retry time is 200 * 100 ms => 20 sec
int tries = 0;
do {
try {
@@ -150,7 +149,7 @@ public class TestHTableMultiplexer {
*
* @throws Exception
*/
- @Test
+ @Test(timeout = 150000)
public void testCounters() throws Exception {
byte[] TABLE = Bytes.toBytes("testCounters");
Configuration conf = TEST_UTIL.getConfiguration();