HBASE-14698 Set category timeouts on TestScanner and TestNamespaceAuditor

This commit is contained in:
stack 2015-10-26 12:55:36 -07:00
parent 4c04e8065f
commit 0f6ec611e6
3 changed files with 17 additions and 10 deletions

View File

@ -32,9 +32,6 @@ import java.util.List;
import java.util.Random; import java.util.Random;
import org.apache.hadoop.hbase.CategoryBasedTimeout; import org.apache.hadoop.hbase.CategoryBasedTimeout;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellComparator;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.HBaseTestingUtility; import org.apache.hadoop.hbase.HBaseTestingUtility;
import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.HConstants;
import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.KeyValue;

View File

@ -37,6 +37,7 @@ import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path; import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hbase.CategoryBasedTimeout;
import org.apache.hadoop.hbase.Coprocessor; import org.apache.hadoop.hbase.Coprocessor;
import org.apache.hadoop.hbase.CoprocessorEnvironment; import org.apache.hadoop.hbase.CoprocessorEnvironment;
import org.apache.hadoop.hbase.DoNotRetryIOException; import org.apache.hadoop.hbase.DoNotRetryIOException;
@ -85,13 +86,17 @@ import org.junit.After;
import org.junit.AfterClass; import org.junit.AfterClass;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.junit.Ignore; import org.junit.Ignore;
import org.junit.Rule;
import org.junit.Test; import org.junit.Test;
import org.junit.experimental.categories.Category; import org.junit.experimental.categories.Category;
import org.junit.rules.TestRule;
import com.google.common.collect.Sets; import com.google.common.collect.Sets;
@Category(MediumTests.class) @Category(MediumTests.class)
public class TestNamespaceAuditor { public class TestNamespaceAuditor {
@Rule public final TestRule timeout = CategoryBasedTimeout.builder().
withTimeout(this.getClass()).withLookingForStuckThread(true).build();
private static final Log LOG = LogFactory.getLog(TestNamespaceAuditor.class); private static final Log LOG = LogFactory.getLog(TestNamespaceAuditor.class);
private static final HBaseTestingUtility UTIL = new HBaseTestingUtility(); private static final HBaseTestingUtility UTIL = new HBaseTestingUtility();
private static HBaseAdmin ADMIN; private static HBaseAdmin ADMIN;
@ -133,7 +138,7 @@ public class TestNamespaceAuditor {
.getMasterQuotaManager().isQuotaEnabled()); .getMasterQuotaManager().isQuotaEnabled());
} }
@Test(timeout = 60000) @Test
public void testTableOperations() throws Exception { public void testTableOperations() throws Exception {
String nsp = prefix + "_np2"; String nsp = prefix + "_np2";
NamespaceDescriptor nspDesc = NamespaceDescriptor nspDesc =
@ -480,7 +485,7 @@ public class TestNamespaceAuditor {
* namespace quota cache. Now correct the failure and recreate the table with same name. * namespace quota cache. Now correct the failure and recreate the table with same name.
* HBASE-13394 * HBASE-13394
*/ */
@Test(timeout = 180000) @Test
public void testRecreateTableWithSameNameAfterFirstTimeFailure() throws Exception { public void testRecreateTableWithSameNameAfterFirstTimeFailure() throws Exception {
String nsp1 = prefix + "_testRecreateTable"; String nsp1 = prefix + "_testRecreateTable";
NamespaceDescriptor nspDesc = NamespaceDescriptor nspDesc =
@ -659,7 +664,7 @@ public class TestNamespaceAuditor {
observer.tableDeletionLatch.await(); observer.tableDeletionLatch.await();
} }
@Test(expected = QuotaExceededException.class, timeout = 30000) @Test(expected = QuotaExceededException.class)
public void testExceedTableQuotaInNamespace() throws Exception { public void testExceedTableQuotaInNamespace() throws Exception {
String nsp = prefix + "_testExceedTableQuotaInNamespace"; String nsp = prefix + "_testExceedTableQuotaInNamespace";
NamespaceDescriptor nspDesc = NamespaceDescriptor nspDesc =
@ -676,7 +681,7 @@ public class TestNamespaceAuditor {
ADMIN.createTable(tableDescTwo, Bytes.toBytes("AAA"), Bytes.toBytes("ZZZ"), 4); ADMIN.createTable(tableDescTwo, Bytes.toBytes("AAA"), Bytes.toBytes("ZZZ"), 4);
} }
@Test(expected = QuotaExceededException.class, timeout = 30000) @Test(expected = QuotaExceededException.class)
public void testCloneSnapshotQuotaExceed() throws Exception { public void testCloneSnapshotQuotaExceed() throws Exception {
String nsp = prefix + "_testTableQuotaExceedWithCloneSnapshot"; String nsp = prefix + "_testTableQuotaExceedWithCloneSnapshot";
NamespaceDescriptor nspDesc = NamespaceDescriptor nspDesc =
@ -694,7 +699,7 @@ public class TestNamespaceAuditor {
ADMIN.deleteSnapshot(snapshot); ADMIN.deleteSnapshot(snapshot);
} }
@Test(timeout = 180000) @Test
public void testCloneSnapshot() throws Exception { public void testCloneSnapshot() throws Exception {
String nsp = prefix + "_testCloneSnapshot"; String nsp = prefix + "_testCloneSnapshot";
NamespaceDescriptor nspDesc = NamespaceDescriptor nspDesc =
@ -729,7 +734,7 @@ public class TestNamespaceAuditor {
ADMIN.deleteSnapshot(snapshot); ADMIN.deleteSnapshot(snapshot);
} }
@Test(timeout = 180000) @Test
public void testRestoreSnapshot() throws Exception { public void testRestoreSnapshot() throws Exception {
String nsp = prefix + "_testRestoreSnapshot"; String nsp = prefix + "_testRestoreSnapshot";
NamespaceDescriptor nspDesc = NamespaceDescriptor nspDesc =
@ -763,7 +768,7 @@ public class TestNamespaceAuditor {
ADMIN.deleteSnapshot(snapshot); ADMIN.deleteSnapshot(snapshot);
} }
@Test(timeout = 180000) @Test
public void testRestoreSnapshotQuotaExceed() throws Exception { public void testRestoreSnapshotQuotaExceed() throws Exception {
String nsp = prefix + "_testRestoreSnapshotQuotaExceed"; String nsp = prefix + "_testRestoreSnapshotQuotaExceed";
NamespaceDescriptor nspDesc = NamespaceDescriptor nspDesc =

View File

@ -33,6 +33,7 @@ import java.util.List;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.hbase.CategoryBasedTimeout;
import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil; import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.HBaseTestCase; import org.apache.hadoop.hbase.HBaseTestCase;
@ -61,6 +62,7 @@ import org.junit.Rule;
import org.junit.Test; import org.junit.Test;
import org.junit.experimental.categories.Category; import org.junit.experimental.categories.Category;
import org.junit.rules.TestName; import org.junit.rules.TestName;
import org.junit.rules.TestRule;
/** /**
* Test of a long-lived scanner validating as we go. * Test of a long-lived scanner validating as we go.
@ -68,6 +70,9 @@ import org.junit.rules.TestName;
@Category({RegionServerTests.class, SmallTests.class}) @Category({RegionServerTests.class, SmallTests.class})
public class TestScanner { public class TestScanner {
@Rule public TestName name = new TestName(); @Rule public TestName name = new TestName();
@Rule public final TestRule timeout = CategoryBasedTimeout.builder().
withTimeout(this.getClass()).withLookingForStuckThread(true).build();
private static final Log LOG = LogFactory.getLog(TestScanner.class); private static final Log LOG = LogFactory.getLog(TestScanner.class);
private final static HBaseTestingUtility TEST_UTIL = HBaseTestingUtility.createLocalHTU(); private final static HBaseTestingUtility TEST_UTIL = HBaseTestingUtility.createLocalHTU();